[jira] [Resolved] (KAFKA-7412) Bug prone response from producer.send(ProducerRecord, Callback) if Kafka broker is not running

[ https://issues.apache.org/jira/browse/KAFKA-7412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-7412. Resolution: Fixed Fix Version/s: 2.2.0 Clarified the javadoc in producer callback. Metadata is not

[jira] [Commented] (KAFKA-7412) Bug prone response from producer.send(ProducerRecord, Callback) if Kafka broker is not running

[ https://issues.apache.org/jira/browse/KAFKA-7412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16680684#comment-16680684 ] ASF GitHub Bot commented on KAFKA-7412: --- junrao closed pull request #5798: KAFKA-7412: onComplete

[jira] [Commented] (KAFKA-7549) Old ProduceRequest with zstd compression does not return error to client

[ https://issues.apache.org/jira/browse/KAFKA-7549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16680509#comment-16680509 ] Dong Lin commented on KAFKA-7549: - [~ijuma] [~hachikuji] Given the reasoning provided above, are you OK

[jira] [Resolved] (KAFKA-6641) Consider auto repartitioning for Stream.transform() API

[ https://issues.apache.org/jira/browse/KAFKA-6641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6641. Resolution: Duplicate > Consider auto repartitioning for Stream.transform() API >

[jira] [Commented] (KAFKA-7165) Error while creating ephemeral at /brokers/ids/BROKER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16680420#comment-16680420 ] ASF GitHub Bot commented on KAFKA-7165: --- junrao closed pull request #5575: KAFKA-7165: Retry the

[jira] [Commented] (KAFKA-4972) Kafka 0.10.0 Found a corrupted index file during Kafka broker startup

[ https://issues.apache.org/jira/browse/KAFKA-4972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679867#comment-16679867 ] Nenad Maric commented on KAFKA-4972: Any news about this bug? We have a similar problem on Kafka

[jira] [Commented] (KAFKA-5503) Idempotent producer ignores shutdown while fetching ProducerId

[ https://issues.apache.org/jira/browse/KAFKA-5503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679865#comment-16679865 ] ASF GitHub Bot commented on KAFKA-5503: --- layfe closed pull request #5881: KAFKA-5503 Idempotent

[jira] [Comment Edited] (KAFKA-6641) Consider auto repartitioning for Stream.transform() API

[ https://issues.apache.org/jira/browse/KAFKA-6641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679272#comment-16679272 ] Andy Bryant edited comment on KAFKA-6641 at 11/8/18 4:22 AM: - This is done

[jira] [Commented] (KAFKA-5503) Idempotent producer ignores shutdown while fetching ProducerId

[ https://issues.apache.org/jira/browse/KAFKA-5503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679866#comment-16679866 ] ASF GitHub Bot commented on KAFKA-5503: --- layfe opened a new pull request #5881: KAFKA-5503

[jira] [Closed] (KAFKA-7431) Clean up connect unit tests code

[ https://issues.apache.org/jira/browse/KAFKA-7431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Srinivas Reddy closed KAFKA-7431. - > Clean up connect unit tests code > > > Key:

[jira] [Updated] (KAFKA-7313) StopReplicaRequest should attempt to remove future replica for the partition only if future replica exists

[ https://issues.apache.org/jira/browse/KAFKA-7313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-7313: - Fix Version/s: (was: 2.0.1) 2.0.2 > StopReplicaRequest should attempt to remove

[jira] [Commented] (KAFKA-7605) Flaky Test `SaslMultiMechanismConsumerTest.testCoordinatorFailover`

[ https://issues.apache.org/jira/browse/KAFKA-7605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679106#comment-16679106 ] ASF GitHub Bot commented on KAFKA-7605: --- hachikuji opened a new pull request #5890: KAFKA-7605;

[jira] [Updated] (KAFKA-7608) A Kafka Streams DSL transform or process call should trigger a repartition, like a join

[ https://issues.apache.org/jira/browse/KAFKA-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andy Bryant updated KAFKA-7608: --- Summary: A Kafka Streams DSL transform or process call should trigger a repartition, like a join

[jira] [Updated] (KAFKA-7608) A Kafka Streams DSL transform or process call should potentially trigger a repartition

[ https://issues.apache.org/jira/browse/KAFKA-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andy Bryant updated KAFKA-7608: --- Summary: A Kafka Streams DSL transform or process call should potentially trigger a repartition

[jira] [Commented] (KAFKA-5503) Idempotent producer ignores shutdown while fetching ProducerId

[ https://issues.apache.org/jira/browse/KAFKA-5503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679585#comment-16679585 ] ASF GitHub Bot commented on KAFKA-5503: --- layfe opened a new pull request #5881: KAFKA-5503

[jira] [Commented] (KAFKA-5503) Idempotent producer ignores shutdown while fetching ProducerId

[ https://issues.apache.org/jira/browse/KAFKA-5503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679682#comment-16679682 ] ASF GitHub Bot commented on KAFKA-5503: --- layfe opened a new pull request #5881: KAFKA-5503

[jira] [Commented] (KAFKA-6641) Consider auto repartitioning for Stream.transform() API

[ https://issues.apache.org/jira/browse/KAFKA-6641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679272#comment-16679272 ] Andy Bryant commented on KAFKA-6641: This is done now by the looks. In KStreamImpl.transform it

[jira] [Commented] (KAFKA-6812) Async ConsoleProducer exits with 0 status even after data loss

[ https://issues.apache.org/jira/browse/KAFKA-6812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16680331#comment-16680331 ] Stanislav Kozlovski commented on KAFKA-6812: Hey [~kamalkang], the best way is to directly

[jira] [Created] (KAFKA-7609) Add Protocol Generator for Kafka

Colin P. McCabe created KAFKA-7609: -- Summary: Add Protocol Generator for Kafka Key: KAFKA-7609 URL: https://issues.apache.org/jira/browse/KAFKA-7609 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-7534) Error during CachingKeyValueStore.flush may not allow RocksDB to close

[ https://issues.apache.org/jira/browse/KAFKA-7534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7534: --- Fix Version/s: 2.0.2 > Error during CachingKeyValueStore.flush may not allow RocksDB to

[jira] [Commented] (KAFKA-6812) Async ConsoleProducer exits with 0 status even after data loss

[ https://issues.apache.org/jira/browse/KAFKA-6812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16680175#comment-16680175 ] Kamal Kang commented on KAFKA-6812: --- [~enether]- How do I get permissions to write KIP? > Async

[jira] [Commented] (KAFKA-7609) Add Protocol Generator for Kafka

[ https://issues.apache.org/jira/browse/KAFKA-7609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16680166#comment-16680166 ] ASF GitHub Bot commented on KAFKA-7609: --- cmccabe opened a new pull request #5893: KAFKA-7609: Add

[jira] [Commented] (KAFKA-5503) Idempotent producer ignores shutdown while fetching ProducerId

[ https://issues.apache.org/jira/browse/KAFKA-5503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679584#comment-16679584 ] ASF GitHub Bot commented on KAFKA-5503: --- layfe closed pull request #5881: KAFKA-5503 Idempotent

[jira] [Created] (KAFKA-7608) A Kafka Streams DSL transform or processor call should trigger a repartition like a join

Andy Bryant created KAFKA-7608: -- Summary: A Kafka Streams DSL transform or processor call should trigger a repartition like a join Key: KAFKA-7608 URL: https://issues.apache.org/jira/browse/KAFKA-7608

[jira] [Commented] (KAFKA-7604) Flaky Test `ConsumerCoordinatorTest.testRebalanceAfterTopicUnavailableWithPatternSubscribe`

[ https://issues.apache.org/jira/browse/KAFKA-7604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679763#comment-16679763 ] ASF GitHub Bot commented on KAFKA-7604: --- rajinisivaram closed pull request #5889: KAFKA-7604; Fix

[jira] [Commented] (KAFKA-7581) Issues in building kafka using gradle on a Ubuntu based docker container

[ https://issues.apache.org/jira/browse/KAFKA-7581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679496#comment-16679496 ] 点儿郎当 commented on KAFKA-7581: - 兄弟，我们线上kafka出了个问题，版本是1.0，三台brokers，默认12个 partition,2个副本 问题场景：      

[jira] [Created] (KAFKA-7606) Remove deprecated --zookeeper option from StreamsResetter

Matthias J. Sax created KAFKA-7606: -- Summary: Remove deprecated --zookeeper option from StreamsResetter Key: KAFKA-7606 URL: https://issues.apache.org/jira/browse/KAFKA-7606 Project: Kafka

[jira] [Commented] (KAFKA-5503) Idempotent producer ignores shutdown while fetching ProducerId

[ https://issues.apache.org/jira/browse/KAFKA-5503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679681#comment-16679681 ] ASF GitHub Bot commented on KAFKA-5503: --- layfe closed pull request #5881: KAFKA-5503 Idempotent

[jira] [Updated] (KAFKA-7608) A Kafka Streams DSL transform or process call should potentially trigger a repartition

[ https://issues.apache.org/jira/browse/KAFKA-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7608: --- Issue Type: Improvement (was: Bug) > A Kafka Streams DSL transform or process call should

[jira] [Updated] (KAFKA-7559) ConnectStandaloneFileTest system tests do not pass

[ https://issues.apache.org/jira/browse/KAFKA-7559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-7559: - Fix Version/s: (was: 2.0.1) 2.0.2 > ConnectStandaloneFileTest system tests do not