[jira] [Commented] (KAFKA-7704) kafka.server.ReplicaFetechManager.MaxLag.Replica metric is reported incorrectly

[ https://issues.apache.org/jira/browse/KAFKA-7704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709589#comment-16709589 ] Jun Rao commented on KAFKA-7704: [~yuyang08], could you try the PR and see if it fixes the issue? Thanks,

[jira] [Commented] (KAFKA-2729) Cached zkVersion not equal to that in zookeeper, broker not recovering.

[ https://issues.apache.org/jira/browse/KAFKA-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709539#comment-16709539 ] Jun Rao commented on KAFKA-2729: We fixed another issue that can fail the re-creation of the broker

[jira] [Commented] (KAFKA-7660) Stream Metrics - Memory Analysis

[ https://issues.apache.org/jira/browse/KAFKA-7660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709302#comment-16709302 ] ASF GitHub Bot commented on KAFKA-7660: --- mjsax closed pull request #5980: KAFKA-7660: fix streams

[jira] [Commented] (KAFKA-7660) Stream Metrics - Memory Analysis

[ https://issues.apache.org/jira/browse/KAFKA-7660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709296#comment-16709296 ] ASF GitHub Bot commented on KAFKA-7660: --- mjsax closed pull request #5979: KAFKA-7660: fix streams

[jira] [Commented] (KAFKA-7695) Cannot override StreamsPartitionAssignor in configuration

[ https://issues.apache.org/jira/browse/KAFKA-7695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709278#comment-16709278 ] Matthias J. Sax commented on KAFKA-7695: Thanks for the details. I would highly recommend to try

[jira] [Updated] (KAFKA-7705) Update javadoc for the values of delivery.timeout.ms or linger.ms

[ https://issues.apache.org/jira/browse/KAFKA-7705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-7705: Component/s: producer clients > Update javadoc for the values of

[jira] [Commented] (KAFKA-7695) Cannot override StreamsPartitionAssignor in configuration

[ https://issues.apache.org/jira/browse/KAFKA-7695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709229#comment-16709229 ] Dmitry Buykin commented on KAFKA-7695: -- [~mjsax]   {quote}In our application we have quite large

[jira] [Commented] (KAFKA-7699) Improve wall-clock time punctuations

[ https://issues.apache.org/jira/browse/KAFKA-7699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709173#comment-16709173 ] Matthias J. Sax commented on KAFKA-7699: {quote}would you want to epoch-align it like the window

[jira] [Commented] (KAFKA-7695) Cannot override StreamsPartitionAssignor in configuration

[ https://issues.apache.org/jira/browse/KAFKA-7695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709166#comment-16709166 ] Matthias J. Sax commented on KAFKA-7695: I guess I was distracted by "global consumer" and the

[jira] [Commented] (KAFKA-6144) Allow state stores to serve stale reads during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709086#comment-16709086 ] Navinder Brar commented on KAFKA-6144: -- Is someone working on a patch for this? If I understand

[jira] [Assigned] (KAFKA-6144) Allow state stores to serve stale reads during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nikolay Izhikov reassigned KAFKA-6144: -- Assignee: Nikolay Izhikov > Allow state stores to serve stale reads during rebalance

[jira] [Updated] (KAFKA-6555) Making state store queryable during restoration

[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6555: --- Flags: (was: Important) > Making state store queryable during restoration >

[jira] [Resolved] (KAFKA-7687) Print batch level information in DumpLogSegments when deep iterating

[ https://issues.apache.org/jira/browse/KAFKA-7687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7687. Resolution: Fixed Fix Version/s: 2.2.0 > Print batch level information in

[jira] [Commented] (KAFKA-7660) Stream Metrics - Memory Analysis

[ https://issues.apache.org/jira/browse/KAFKA-7660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708953#comment-16708953 ] John Roesler commented on KAFKA-7660: - Sounds good! We'll go ahead and leave this ticket "resolved",

[jira] [Commented] (KAFKA-7699) Improve wall-clock time punctuations

[ https://issues.apache.org/jira/browse/KAFKA-7699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708883#comment-16708883 ] John Roesler commented on KAFKA-7699: - Interesting thought! For anchored schedules, would you want to

[jira] [Commented] (KAFKA-7697) Possible deadlock in kafka.cluster.Partition

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

[jira] [Commented] (KAFKA-7660) Stream Metrics - Memory Analysis

[ https://issues.apache.org/jira/browse/KAFKA-7660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708639#comment-16708639 ] Patrik Kleindl commented on KAFKA-7660: --- [~vvcephei] Will do so when we do the next upgrade cycle,

[jira] [Commented] (KAFKA-7696) kafka-delegation-tokens.sh using a config file that contains security.protocol=SASL_PLAINTEXT throws OutOfMemoryError if it tries to connect to an SSL-enabled secured b

[ https://issues.apache.org/jira/browse/KAFKA-7696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708633#comment-16708633 ] Attila Sasvari commented on KAFKA-7696: --- Thanks [~omkreddy]! Resolving this as a duplicate >

[jira] [Resolved] (KAFKA-7696) kafka-delegation-tokens.sh using a config file that contains security.protocol=SASL_PLAINTEXT throws OutOfMemoryError if it tries to connect to an SSL-enabled secured br

[ https://issues.apache.org/jira/browse/KAFKA-7696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Attila Sasvari resolved KAFKA-7696. --- Resolution: Duplicate > kafka-delegation-tokens.sh using a config file that contains >

[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=16708540#comment-16708540 ] Sebastian Puzoń commented on KAFKA-7625: Upgraded to : {code:java} java version "1.8.0_192"

[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=16708514#comment-16708514 ] Sebastian Puzoń commented on KAFKA-7625: Yes, I will upgrade to latest 1.8 version and monitor.

[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=16708508#comment-16708508 ] Ismael Juma commented on KAFKA-7625: Can you try a newer JVM version? Looks like a JVM bug. > Kafka

[jira] [Resolved] (KAFKA-7702) Prefixed ACLs don't work with single character prefix

[ https://issues.apache.org/jira/browse/KAFKA-7702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-7702. --- Resolution: Fixed Reviewer: Jun Rao > Prefixed ACLs don't work with single character

[jira] [Commented] (KAFKA-7531) NPE NullPointerException at TransactionCoordinator handleEndTransaction

[ https://issues.apache.org/jira/browse/KAFKA-7531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708491#comment-16708491 ] Sebastian Puzoń commented on KAFKA-7531: Do you think this issue is related? Regular JVM Crashes

[jira] [Commented] (KAFKA-7702) Prefixed ACLs don't work with single character prefix

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

[jira] [Comment Edited] (KAFKA-7695) Cannot override StreamsPartitionAssignor in configuration

[ https://issues.apache.org/jira/browse/KAFKA-7695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708417#comment-16708417 ] Dmitry Buykin edited comment on KAFKA-7695 at 12/4/18 9:19 AM: --- [~vvcephei] 

[jira] [Comment Edited] (KAFKA-7695) Cannot override StreamsPartitionAssignor in configuration

[ https://issues.apache.org/jira/browse/KAFKA-7695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708417#comment-16708417 ] Dmitry Buykin edited comment on KAFKA-7695 at 12/4/18 9:13 AM: --- [~vvcephei] 

[jira] [Commented] (KAFKA-7695) Cannot override StreamsPartitionAssignor in configuration

[ https://issues.apache.org/jira/browse/KAFKA-7695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708417#comment-16708417 ] Dmitry Buykin commented on KAFKA-7695: -- [~vvcephei] I'm agree with your comments. It would be better

[jira] [Comment Edited] (KAFKA-7695) Cannot override StreamsPartitionAssignor in configuration

[ https://issues.apache.org/jira/browse/KAFKA-7695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708392#comment-16708392 ] Dmitry Buykin edited comment on KAFKA-7695 at 12/4/18 8:40 AM: --- [~mjsax] I

[jira] [Commented] (KAFKA-2729) Cached zkVersion not equal to that in zookeeper, broker not recovering.

[ https://issues.apache.org/jira/browse/KAFKA-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708393#comment-16708393 ] Bo Wang commented on KAFKA-2729: I also got the same problem with 1.1.0, whether there is a patch or

[jira] [Commented] (KAFKA-7695) Cannot override StreamsPartitionAssignor in configuration

[ https://issues.apache.org/jira/browse/KAFKA-7695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708392#comment-16708392 ] Dmitry Buykin commented on KAFKA-7695: -- [~mjsax] I think it's a bug because KStreams derive settings