[jira] [Commented] (KAFKA-8153) Streaming application with state stores takes up to 1 hour to restart

[ https://issues.apache.org/jira/browse/KAFKA-8153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16820821#comment-16820821 ] Michael Melsen commented on KAFKA-8153: --- No unfortunately disabling the clean up di

[jira] [Commented] (KAFKA-7282) Failed to read `log header` from file channel

[ https://issues.apache.org/jira/browse/KAFKA-7282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16820846#comment-16820846 ] Mootez Bessifi commented on KAFKA-7282: --- [~amunro] any fix for this ?? > Failed to

[jira] [Created] (KAFKA-8254) Suppress incorrectly passes a null topic to the serdes

John Roesler created KAFKA-8254: --- Summary: Suppress incorrectly passes a null topic to the serdes Key: KAFKA-8254 URL: https://issues.apache.org/jira/browse/KAFKA-8254 Project: Kafka Issue Type

[jira] [Assigned] (KAFKA-8254) Suppress incorrectly passes a null topic to the serdes

[ https://issues.apache.org/jira/browse/KAFKA-8254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-8254: --- Assignee: John Roesler > Suppress incorrectly passes a null topic to the serdes > --

[jira] [Commented] (KAFKA-7026) Sticky assignor could assign a partition to multiple consumers (KIP-341)

[ https://issues.apache.org/jira/browse/KAFKA-7026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16821228#comment-16821228 ] ASF GitHub Bot commented on KAFKA-7026: --- hachikuji commented on pull request #5291:

[jira] [Resolved] (KAFKA-7026) Sticky assignor could assign a partition to multiple consumers (KIP-341)

[ https://issues.apache.org/jira/browse/KAFKA-7026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7026. Resolution: Fixed Fix Version/s: 2.3.0 > Sticky assignor could assign a partition to

[jira] [Commented] (KAFKA-8254) Suppress incorrectly passes a null topic to the serdes

[ https://issues.apache.org/jira/browse/KAFKA-8254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16821230#comment-16821230 ] ASF GitHub Bot commented on KAFKA-8254: --- vvcephei commented on pull request #6602:

[jira] [Commented] (KAFKA-7866) Duplicate offsets after transaction index append failure

[ https://issues.apache.org/jira/browse/KAFKA-7866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16821238#comment-16821238 ] ASF GitHub Bot commented on KAFKA-7866: --- hachikuji commented on pull request #6570:

[jira] [Commented] (KAFKA-7026) Sticky assignor could assign a partition to multiple consumers (KIP-341)

[ https://issues.apache.org/jira/browse/KAFKA-7026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16821254#comment-16821254 ] Michael K. Edwards commented on KAFKA-7026: --- Thank you [~vahid] and reviewers! 

[jira] [Commented] (KAFKA-6598) Kafka to support using ETCD beside Zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-6598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16821255#comment-16821255 ] K. C. Tessarek commented on KAFKA-6598: --- I'd also like to know the status of this.

[jira] [Resolved] (KAFKA-7652) Kafka Streams Session store performance degradation from 0.10.2.2 to 0.11.0.0

[ https://issues.apache.org/jira/browse/KAFKA-7652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7652. -- Resolution: Fixed Fix Version/s: 2.3.0 It should be fixed by the latest PR (details abou

[jira] [Commented] (KAFKA-7026) Sticky assignor could assign a partition to multiple consumers (KIP-341)

[ https://issues.apache.org/jira/browse/KAFKA-7026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16821274#comment-16821274 ] Michael K. Edwards commented on KAFKA-7026: --- How confident are we that analogou

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16821276#comment-16821276 ] Bill Bejeck commented on KAFKA-7965: Failed again,  [https://builds.apache.org/job/k

[jira] [Created] (KAFKA-8255) Replica fetcher thread exits with OffsetOutOfRangeException

Colin P. McCabe created KAFKA-8255: -- Summary: Replica fetcher thread exits with OffsetOutOfRangeException Key: KAFKA-8255 URL: https://issues.apache.org/jira/browse/KAFKA-8255 Project: Kafka

[jira] [Updated] (KAFKA-8185) Controller becomes stale and not able to failover the leadership for the partitions

[ https://issues.apache.org/jira/browse/KAFKA-8185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kang H Lee updated KAFKA-8185: -- Attachment: (was: broker9.zip) > Controller becomes stale and not able to failover the leadership f

[jira] [Updated] (KAFKA-8185) Controller becomes stale and not able to failover the leadership for the partitions

[ https://issues.apache.org/jira/browse/KAFKA-8185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kang H Lee updated KAFKA-8185: -- Attachment: (was: broker12.zip) > Controller becomes stale and not able to failover the leadership

[jira] [Updated] (KAFKA-8185) Controller becomes stale and not able to failover the leadership for the partitions

[ https://issues.apache.org/jira/browse/KAFKA-8185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kang H Lee updated KAFKA-8185: -- Attachment: (was: zookeeper.zip) > Controller becomes stale and not able to failover the leadership

[jira] [Created] (KAFKA-8256) Replace Heartbeat request/response with automated protocol

Mickael Maison created KAFKA-8256: - Summary: Replace Heartbeat request/response with automated protocol Key: KAFKA-8256 URL: https://issues.apache.org/jira/browse/KAFKA-8256 Project: Kafka Is

[jira] [Commented] (KAFKA-8235) NoSuchElementException when restoring state after a clean shutdown of a Kafka Streams application

[ https://issues.apache.org/jira/browse/KAFKA-8235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16821363#comment-16821363 ] John Roesler commented on KAFKA-8235: - Hey [~AndrewRK], Sorry about that. I failed t

[jira] [Commented] (KAFKA-8030) Flaky Test TopicCommandWithAdminClientTest#testDescribeUnderMinIsrPartitionsMixed

[ https://issues.apache.org/jira/browse/KAFKA-8030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16821368#comment-16821368 ] Matthias J. Sax commented on KAFKA-8030: Failed again:  [https://builds.apache.or

[jira] [Updated] (KAFKA-8257) Flaky Test DynamicConnectionQuotaTest#testDynamicListenerConnectionQuota

[ https://issues.apache.org/jira/browse/KAFKA-8257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8257: --- Issue Type: Bug (was: Improvement) > Flaky Test DynamicConnectionQuotaTest#testDynamicListen

[jira] [Created] (KAFKA-8257) Flaky Test DynamicConnectionQuotaTest#testDynamicListenerConnectionQuota

Matthias J. Sax created KAFKA-8257: -- Summary: Flaky Test DynamicConnectionQuotaTest#testDynamicListenerConnectionQuota Key: KAFKA-8257 URL: https://issues.apache.org/jira/browse/KAFKA-8257 Project: K

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16821388#comment-16821388 ] Matthias J. Sax commented on KAFKA-7965: [~bbejeck] The patch was merged yesterda

[jira] [Commented] (KAFKA-7026) Sticky assignor could assign a partition to multiple consumers (KIP-341)

[ https://issues.apache.org/jira/browse/KAFKA-7026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16821391#comment-16821391 ] Matthias J. Sax commented on KAFKA-7026: Pretty confident. > Sticky assignor cou

[jira] [Assigned] (KAFKA-8248) Producer may fail IllegalStateException

[ https://issues.apache.org/jira/browse/KAFKA-8248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8248: -- Assignee: Matthias J. Sax > Producer may fail IllegalStateException >

[jira] [Resolved] (KAFKA-7866) Duplicate offsets after transaction index append failure

[ https://issues.apache.org/jira/browse/KAFKA-7866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7866. Resolution: Fixed Assignee: Jason Gustafson Fix Version/s: 2.2.1

[jira] [Commented] (KAFKA-8248) Producer may fail IllegalStateException

[ https://issues.apache.org/jira/browse/KAFKA-8248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16821393#comment-16821393 ] Matthias J. Sax commented on KAFKA-8248: It was reported for `2.0.0` but we assum

[jira] [Commented] (KAFKA-7026) Sticky assignor could assign a partition to multiple consumers (KIP-341)

[ https://issues.apache.org/jira/browse/KAFKA-7026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16821419#comment-16821419 ] Michael K. Edwards commented on KAFKA-7026: --- Good enough for me.  Thank you. >

[jira] [Created] (KAFKA-8258) Verbose logs in org.apache.kafka.clients.consumer.internals.Fetcher

Shixiong Zhu created KAFKA-8258: --- Summary: Verbose logs in org.apache.kafka.clients.consumer.internals.Fetcher Key: KAFKA-8258 URL: https://issues.apache.org/jira/browse/KAFKA-8258 Project: Kafka

[jira] [Updated] (KAFKA-8258) Verbose logs in org.apache.kafka.clients.consumer.internals.Fetcher

[ https://issues.apache.org/jira/browse/KAFKA-8258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shixiong Zhu updated KAFKA-8258: Description: We noticed that the Spark's Kafka connector outputs a lot of following verbose logs:

[jira] [Assigned] (KAFKA-7760) Add broker configuration to set minimum value for segment.bytes and segment.ms

[ https://issues.apache.org/jira/browse/KAFKA-7760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brandt Newton reassigned KAFKA-7760: Assignee: Brandt Newton > Add broker configuration to set minimum value for segment.bytes

[jira] [Created] (KAFKA-8259) Build RPM for Kafka

Patrick Dignan created KAFKA-8259: - Summary: Build RPM for Kafka Key: KAFKA-8259 URL: https://issues.apache.org/jira/browse/KAFKA-8259 Project: Kafka Issue Type: Improvement Compone

[jira] [Assigned] (KAFKA-6819) Refactor build-in StreamsMetrics internal implementations

[ https://issues.apache.org/jira/browse/KAFKA-6819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reassigned KAFKA-6819: Assignee: Bruno Cadonna > Refactor build-in StreamsMetrics internal implementations >

[jira] [Created] (KAFKA-8260) Flaky test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

John Roesler created KAFKA-8260: --- Summary: Flaky test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup Key: KAFKA-8260 URL: https://issues.apache.org/jira/browse/KAFKA-8260

[jira] [Updated] (KAFKA-8260) Flaky test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-8260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-8260: Description: I have seen this fail again just now. See also KAFKA-7965 and KAFKA-7936. https://bui

[jira] [Commented] (KAFKA-8245) Flaky Test DeleteConsumerGroupsTest#testDeleteCmdAllGroups

[ https://issues.apache.org/jira/browse/KAFKA-8245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16821491#comment-16821491 ] John Roesler commented on KAFKA-8245: - Saw this again: https://builds.apache.org/job/

[jira] [Updated] (KAFKA-7847) KIP-421: Automatically resolve external configurations.

[ https://issues.apache.org/jira/browse/KAFKA-7847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TEJAL ADSUL updated KAFKA-7847: --- Summary: KIP-421: Automatically resolve external configurations. (was: KIP-421: Support resolving ex

[jira] [Commented] (KAFKA-8153) Streaming application with state stores takes up to 1 hour to restart

[ https://issues.apache.org/jira/browse/KAFKA-8153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16821528#comment-16821528 ] Matthias J. Sax commented on KAFKA-8153: >  Perhaps tasks are reshuffled among di

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16821530#comment-16821530 ] Matthias J. Sax commented on KAFKA-7672: [~guozhang] Do  you think it might be wo

[jira] [Commented] (KAFKA-6958) Allow to define custom processor names with KStreams DSL

[ https://issues.apache.org/jira/browse/KAFKA-6958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16821548#comment-16821548 ] ASF GitHub Bot commented on KAFKA-6958: --- bbejeck commented on pull request #6410: K

[jira] [Commented] (KAFKA-8248) Producer may fail IllegalStateException

[ https://issues.apache.org/jira/browse/KAFKA-8248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16821561#comment-16821561 ] ASF GitHub Bot commented on KAFKA-8248: --- mjsax commented on pull request #6607: KAF

[jira] [Commented] (KAFKA-7647) Flaky test LogCleanerParameterizedIntegrationTest.testCleansCombinedCompactAndDeleteTopic

[ https://issues.apache.org/jira/browse/KAFKA-7647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16821586#comment-16821586 ] Matthias J. Sax commented on KAFKA-7647: [https://builds.apache.org/blue/organiza

[jira] [Updated] (KAFKA-7647) Flaky test LogCleanerParameterizedIntegrationTest.testCleansCombinedCompactAndDeleteTopic

[ https://issues.apache.org/jira/browse/KAFKA-7647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7647: --- Affects Version/s: 2.1.1 > Flaky test > LogCleanerParameterizedIntegrationTest.testCleansCom

[jira] [Reopened] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reopened KAFKA-7965: Assignee: Jason Gustafson (was: huxihx) I'm still seeing this:  [https://builds.apache.o

[jira] [Commented] (KAFKA-4212) Add a key-value store that is a TTL persistent cache

[ https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16821608#comment-16821608 ] Matthias J. Sax commented on KAFKA-4212: If you configures topic cleanup policy a

[jira] [Updated] (KAFKA-8108) Flaky Test kafka.api.ClientIdQuotaTest.testThrottledProducerConsumer

[ https://issues.apache.org/jira/browse/KAFKA-8108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8108: --- Issue Type: Bug (was: Improvement) > Flaky Test kafka.api.ClientIdQuotaTest.testThrottledPro

[jira] [Updated] (KAFKA-8108) Flaky Test kafka.api.ClientIdQuotaTest.testThrottledProducerConsumer

[ https://issues.apache.org/jira/browse/KAFKA-8108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8108: --- Priority: Critical (was: Major) > Flaky Test kafka.api.ClientIdQuotaTest.testThrottledProduc

[jira] [Updated] (KAFKA-8108) Flaky Test kafka.api.ClientIdQuotaTest.testThrottledProducerConsumer

[ https://issues.apache.org/jira/browse/KAFKA-8108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8108: --- Labels: flaky-test (was: ) > Flaky Test kafka.api.ClientIdQuotaTest.testThrottledProducerCon

[jira] [Updated] (KAFKA-8108) Flaky Test kafka.api.ClientIdQuotaTest.testThrottledProducerConsumer

[ https://issues.apache.org/jira/browse/KAFKA-8108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8108: --- Affects Version/s: 2.3.0 > Flaky Test kafka.api.ClientIdQuotaTest.testThrottledProducerConsum

[jira] [Updated] (KAFKA-8108) Flaky Test kafka.api.ClientIdQuotaTest.testThrottledProducerConsumer

[ https://issues.apache.org/jira/browse/KAFKA-8108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8108: --- Fix Version/s: 2.3.0 > Flaky Test kafka.api.ClientIdQuotaTest.testThrottledProducerConsumer >

[jira] [Commented] (KAFKA-8108) Flaky Test kafka.api.ClientIdQuotaTest.testThrottledProducerConsumer

[ https://issues.apache.org/jira/browse/KAFKA-8108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16821620#comment-16821620 ] Matthias J. Sax commented on KAFKA-8108: [https://builds.apache.org/job/kafka-pr-

[jira] [Updated] (KAFKA-8108) Flaky Test kafka.api.ClientIdQuotaTest.testThrottledProducerConsumer

[ https://issues.apache.org/jira/browse/KAFKA-8108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8108: --- Component/s: core > Flaky Test kafka.api.ClientIdQuotaTest.testThrottledProducerConsumer > --

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16821626#comment-16821626 ] ASF GitHub Bot commented on KAFKA-7965: --- hachikuji commented on pull request #6608: