[jira] [Created] (KAFKA-13179) High kafka latency on simple benchmark

Vitaly Romashkin created KAFKA-13179: Summary: High kafka latency on simple benchmark Key: KAFKA-13179 URL: https://issues.apache.org/jira/browse/KAFKA-13179 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-13177) partition failures and fewer shrink but a lot of isr expansions with increased num.replica.fetchers in kafka brokers

[ https://issues.apache.org/jira/browse/KAFKA-13177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] kaushik srinivas resolved KAFKA-13177. -- Resolution: Not A Bug > partition failures and fewer shrink but a lot of isr

Re: Handling retriable exceptions during Connect source task start

Hi, To ask slightly differently: would there be interest in a pull request for implementing retries, in case RetriableException is thrown from the Task::start() method? Thanks, --Gunnar Am Do., 5. Aug. 2021 um 22:27 Uhr schrieb Sergei Morozov : > Hi, > > I'm trying to address an issue in

[jira] [Created] (KAFKA-13180) Data Distribution among partitions not working as Expected

Suriya Vijayaraghavan created KAFKA-13180: - Summary: Data Distribution among partitions not working as Expected Key: KAFKA-13180 URL: https://issues.apache.org/jira/browse/KAFKA-13180 Project:

Re: [DISCUSS] KIP-761: Add total blocked time metric to streams

Hi, With "group", I actually meant the "type" tag. A thread-level metrics in Streams has the following tag "type=stream-thread-metrics" which we also call "group" in the code. I realized now that I mentioned "type" and "group" in my previous e-mail which are synonyms for the same concept.

[jira] [Created] (KAFKA-13181) ReplicaManager should start fetchers on UnfencedBrokerRecords

Jose Armando Garcia Sancio created KAFKA-13181: -- Summary: ReplicaManager should start fetchers on UnfencedBrokerRecords Key: KAFKA-13181 URL: https://issues.apache.org/jira/browse/KAFKA-13181

[jira] [Created] (KAFKA-13182) Input to AbstractFetchetManager::addFetcherForPartition could be simplified

Jose Armando Garcia Sancio created KAFKA-13182: -- Summary: Input to AbstractFetchetManager::addFetcherForPartition could be simplified Key: KAFKA-13182 URL:

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #398

See Changes: -- [...truncated 489388 lines...] [Pipeline] // withEnv [Pipeline] } [Pipeline] // withEnv [Pipeline] } [Pipeline] // withEnv [Pipeline] } [Pipeline] // node

Re: [DISCUSS] KIP-764 Configurable backlog size for creating Acceptor

Hi Haruki, I think it makes sense to have this as a configurable property. I think we should name the property socket.listen.backlog.size for better clarity on what the property configures. Besides that, the proposal looks good to me. David On Wed, Jul 28, 2021 at 8:09 AM Haruki Okada wrote:

Re: High kafka latency on simple benchmark

Having a brief look on your repo I have noticed at least two major API usage issues: 1. When you issue Producer#send you get a future object. It is up to the producer to choose the correct time to send. If you really need to send the messages one by one you should execute Producer#flush and then

[jira] [Created] (KAFKA-13183) Dropping nul key/value records upstream to repartiton topic not tracked via metrics

Matthias J. Sax created KAFKA-13183: --- Summary: Dropping nul key/value records upstream to repartiton topic not tracked via metrics Key: KAFKA-13183 URL: https://issues.apache.org/jira/browse/KAFKA-13183

Re: [VOTE] KIP-740: Use TaskId instead of String for the taskId field in TaskMetadata

I am making a minor update to the KIP renaming the TaskId#namedTopology method to TaskId#topologyName as it returns a string for the name not an object. This has approval to make it into 3.0 already. https://github.com/apache/kafka/pull/11192 best, Walker On Thu, May 20, 2021 at 4:58 PM Sophie

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.0 #88

See

Re: [DISCUSS] KIP-759: Unneeded repartition canceling

Hi Matthias and Sophie! ==1. markAsPartitioned vs extending `selectKey(..)` etc. with a config.== I don't have a strong opinion here, both Sophie's and Matthias' points look convincing for me. I think we should estimate the following: what is the probability that we will ever need to

Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #399

See

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #400

See Changes: -- [...truncated 489671 lines...] [2021-08-09T23:43:09.188Z] [2021-08-09T23:43:09.188Z] ApiVersionsRequestTest >

Re: [DISCUSS] KIP-764 Configurable backlog size for creating Acceptor

Hi, Mao. > we should name the property socket.listen.backlog.size for better clarity Sounds good to me. I updated the KIP to name the property as `socket.listen.backlog.size` . 2021年8月9日(月) 23:30 David Mao : > Hi Haruki, > > I think it makes sense to have this as a configurable property. I

Re: [DISCUSS] KIP-655: Windowed "Distinct" Operation for KStream

> To recap: Could it be that the idea to apply a DISTINCT-aggregation is > for a different use-case than to remove duplicate messages from a KStream? OK, imagine the following: We have 10 thermometers. Each second they transmit the current measured temperature. The id of the thermometer

[jira] [Created] (KAFKA-13184) KafkaProducerException

rajendra created KAFKA-13184: Summary: KafkaProducerException Key: KAFKA-13184 URL: https://issues.apache.org/jira/browse/KAFKA-13184 Project: Kafka Issue Type: Bug Components: config

Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #401

See

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.0 #89

See