[jira] [Commented] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936404#comment-16936404 ] Matthias J. Sax commented on KAFKA-7895: This won't fix for 2.1.2 due to backward

[jira] [Updated] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7895: --- Fix Version/s: (was: 2.1.2) > Ktable supress operator emitting more than one record for t

[jira] [Updated] (KAFKA-8649) Error while rolling update from Kafka Streams 2.0.0 -> Kafka Streams 2.1.0

[ https://issues.apache.org/jira/browse/KAFKA-8649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8649: --- Fix Version/s: (was: 2.0.0) > Error while rolling update from Kafka Streams 2.0.0 -> Kafk

[jira] [Commented] (KAFKA-8233) Helper classes to make it simpler to write test logic with TopologyTestDriver

[ https://issues.apache.org/jira/browse/KAFKA-8233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936337#comment-16936337 ] Matthias J. Sax commented on KAFKA-8233: [~jkarvanen] – I added you to the list o

[jira] [Assigned] (KAFKA-8233) Helper classes to make it simpler to write test logic with TopologyTestDriver

[ https://issues.apache.org/jira/browse/KAFKA-8233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8233: -- Assignee: Jukka Karvanen > Helper classes to make it simpler to write test logic with

[jira] [Updated] (KAFKA-8233) Helper classes to make it simpler to write test logic with TopologyTestDriver

[ https://issues.apache.org/jira/browse/KAFKA-8233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8233: --- Labels: kip (was: needs-kip) > Helper classes to make it simpler to write test logic with To

[jira] [Commented] (KAFKA-8613) Set default grace period to 0

[ https://issues.apache.org/jira/browse/KAFKA-8613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936335#comment-16936335 ] Matthias J. Sax commented on KAFKA-8613: I think the tricky part is expected defa

[jira] [Commented] (KAFKA-8233) Helper classes to make it simpler to write test logic with TopologyTestDriver

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

[jira] [Updated] (KAFKA-8233) Helper classes to make it simpler to write test logic with TopologyTestDriver

[ https://issues.apache.org/jira/browse/KAFKA-8233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jukka Karvanen updated KAFKA-8233: -- Description: When using TopologyTestDriver you need to call ConsumerRecordFactory to create Co

[jira] [Commented] (KAFKA-8931) PR '#6850' fix issue 'KAFKA-8449', but lead to restart all cached tasks, which conflict to the motivation of incremental cooperative rebalancing.

[ https://issues.apache.org/jira/browse/KAFKA-8931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936293#comment-16936293 ] HeryLong commented on KAFKA-8931: - Hi [~kkonstantine]:   Please see the following log,

[jira] [Commented] (KAFKA-8931) PR '#6850' fix issue 'KAFKA-8449', but lead to restart all cached tasks, which conflict to the motivation of incremental cooperative rebalancing.

[ https://issues.apache.org/jira/browse/KAFKA-8931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936251#comment-16936251 ] Konstantine Karantasis commented on KAFKA-8931: --- Hi [~HeryLong], thanks for

[jira] [Commented] (KAFKA-8613) Set default grace period to 0

[ https://issues.apache.org/jira/browse/KAFKA-8613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936225#comment-16936225 ] Bruno Cadonna commented on KAFKA-8613: -- Hi [~vvcephei], I might have been focusing

[jira] [Commented] (KAFKA-8613) Set default grace period to 0

[ https://issues.apache.org/jira/browse/KAFKA-8613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936172#comment-16936172 ] John Roesler commented on KAFKA-8613: - Hey [~cadonna], I just learned of this ticket

[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=16936147#comment-16936147 ] Vahid Hashemian commented on KAFKA-7026: [~redbrick9] Can you please provide deta

[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=16936044#comment-16936044 ] ASF GitHub Bot commented on KAFKA-6958: --- bbejeck commented on pull request #6413: K

[jira] [Resolved] (KAFKA-8086) Flaky Test GroupAuthorizerIntegrationTest#testPatternSubscriptionWithTopicAndGroupRead

[ https://issues.apache.org/jira/browse/KAFKA-8086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8086. -- Resolution: Fixed > Flaky Test > GroupAuthorizerIntegrationTest#testPatternSubscriptionWithTop

[jira] [Commented] (KAFKA-8086) Flaky Test GroupAuthorizerIntegrationTest#testPatternSubscriptionWithTopicAndGroupRead

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

[jira] [Commented] (KAFKA-8896) NoSuchElementException after coordinator move

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

[jira] [Updated] (KAFKA-8859) Refactor Cache-level Streams Metrics

[ https://issues.apache.org/jira/browse/KAFKA-8859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8859: --- Affects Version/s: 2.4.0 > Refactor Cache-level Streams Metrics > ---

[jira] [Updated] (KAFKA-8859) Refactor Cache-level Streams Metrics

[ https://issues.apache.org/jira/browse/KAFKA-8859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8859: --- Fix Version/s: 2.4.0 > Refactor Cache-level Streams Metrics > >

[jira] [Resolved] (KAFKA-8859) Refactor Cache-level Streams Metrics

[ https://issues.apache.org/jira/browse/KAFKA-8859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8859. Resolution: Fixed > Refactor Cache-level Streams Metrics > > >

[jira] [Commented] (KAFKA-8859) Refactor Cache-level Streams Metrics

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

[jira] [Commented] (KAFKA-7888) kafka cluster not recovering - Shrinking ISR from 14,13 to 13 (kafka.cluster.Partition) continously

[ https://issues.apache.org/jira/browse/KAFKA-7888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16935817#comment-16935817 ] Stoyan Stoyanov commented on KAFKA-7888: This happened in version 2.2.1 too. > k

[jira] [Comment Edited] (KAFKA-7625) Kafka Broker node JVM crash - kafka.coordinator.transaction.TransactionCoordinator.$anonfun$handleEndTransaction

[ https://issues.apache.org/jira/browse/KAFKA-7625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16935783#comment-16935783 ] fenghong edited comment on KAFKA-7625 at 9/23/19 12:08 PM: --- The

[jira] [Commented] (KAFKA-7625) Kafka Broker node JVM crash - kafka.coordinator.transaction.TransactionCoordinator.$anonfun$handleEndTransaction

[ https://issues.apache.org/jira/browse/KAFKA-7625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16935783#comment-16935783 ] fenghong commented on KAFKA-7625: -     There are 2 solutions: *1. Upgrade the JDK to ver

[jira] [Commented] (KAFKA-8834) Distinguish URPs caused by reassignment plus other metrics

[ https://issues.apache.org/jira/browse/KAFKA-8834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16935698#comment-16935698 ] Viktor Somogyi-Vass commented on KAFKA-8834: I'll add both then. > Distingui

[jira] [Commented] (KAFKA-8327) Connection to Node2 was disconnected

[ https://issues.apache.org/jira/browse/KAFKA-8327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16935604#comment-16935604 ] Mohit Kumar commented on KAFKA-8327: This has been solved by increasing the value of