Is your feature request related to a problem? Please describe.

There is apache pulsar deploy-monitoring article, it describes how to to collect metrics.

These are exposes metrics (via prometheus endpoint)

https://github.com/apache/pulsar/blob/master/site2/docs/reference-metrics.md

Most of them are performance

Instead of always allocating a fixed size buffer (1,000,000 bytes currently), it should leverage the upfront knowledge of total size of the metadata and allocate Math.min(DEFAULT_BUFFER_LEN, metadata.length()).

Hi everyone,

I have an instance of Airsonic running on PostgreSQL, and activated SQL logs. I found some strange behaviours.

Problem description

This request is run lots of times (several times / minutes / user):

select username, locale, t

Problem description
Documentation for ScalingPolicy.byDataRate does not clearly indicate whether targetKBps uses units of 1000 bytes or 1024 bytes.

Problem location
Pravega client, ScalingPolicy.java

Suggestions for an improvement
Determine the units used and update the documentation.

Hi ,

AthenaX looks like a perfect fit for our usage, we are in the process of building a platform where in users can submit jobs , aggregate and perform sinks. Sadly the docs are not helping, can u share a sample docs which helps understand on how kafka works and sink with es Some of the docs are not relevant with class files not found

When user click Stop in Notification, Does it send an event to react native saying that status is Stop playing streaming song ?

As interface shows below：

    /**
     * <p>
     * Send batch messages to server.
     *
     * @param messages messages to be sent.
     */
    void send(List<Message> messages);

This API can lead to multiple behaviors, such as sending to multiple partitions, or the same partition, so how should we define the behavior of this method?

And this issue exists in many places, suc

Kafka Connector stop if connection with database break with Sink Connector. There should be retry in Sink connector as well. This is available in source connector

In the last section of the tutorial, it goes:
<dependency> <groupId>org.corfudb</groupId> <artifactId>runtime</artifactId> <version>0.1-SNAPSHOT</version> <scope>compile</scope> </dependency>

Directly using this setup incurs an error when launching the app,
causing the server unable to deserialize the corfumsg, such as follows:

io.netty.handler.codec.DecoderExcep

Hi we have 25 topics each topic having 2 partition , we have created connect config having topics.regex, so that connector consumes from all 25 topics with tasks.max set to 50 i.e(one unique consumer per partition) but when we describe the consumer group only two unique consumers are attached to 50 partition.

here's the config:
{
"name": "testConnectorfinalTest04",
"config": {

It was discussed in other issues that in order to facilitate error finding and provide easy way to know what's going on in app we should improve logging and give user easier access to them.

I propose to add dependency on logback which seems to be a very good logging library. I have already started integrating it and wanted to ask what do you t

OS:
Distributor ID: Ubuntu
Description: Ubuntu 18.04.4 LTS
Release: 18.04
Codename: bionic

Hi,
I have Pulsar instance running in standalone mode.
Also I started Pulsar-Manager with docker. Here is the command line:
`docker run -it -p 9527:9527 -e REDIRECT_HOST=http://127.0.0.1 -e REDIRECT_PORT=9527 -e DRIVER_CLASS_NAME=org.postgresql.Driver -e URL='jdbc:postgresql://127.0.0.1:5432/pulsa

We have a [document|https://github.com/hortonworks/streamline/blob/master/docs/REST-API.md] for REST API but this looks like out of sync and also easy to be out of sync.

It would be better if we could document API to the source code of each endpoint, and apply swagger or so to make it some pages.
(Registry project uses swagger.)

In the following code

    @Override
    public DetectorDocument findByUuid(String uuid) {
        val queryBuilder = QueryBuilders.termQuery("uuid", uuid);
        val searchSourceBuilder = elasticsearchUtil.getSourceBuilder(queryBuilder).size(DEFAULT_ES_RESULTS_SIZE);
        val searchRequest = elasticsearchUtil.getSearchRequest(searchSourceBuilder, DETECTOR_INDEX, DETECTOR_DOC_TYPE)

Problem description

Correct lyrics won't be displayed.

Steps to reproduce

On Android:
Play a song -> show lyrics -> It says correct Artist and Title, but then the lyrics of a complete different song (let's say song "A") is shown. I can play any song I want, I will always see the lyrics of song "A".

On Ampache (what I use as backend):
Correct lyrics for each song is being displayed