[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&focusedCommentId=16709589#comment-16709589 ] Jun Rao commented on KAFKA-7704: [~yuyang08], could you try the PR and see if it fixes th

[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&focusedCommentId=16709539#comment-16709539 ] Jun Rao commented on KAFKA-2729: We fixed another issue that can fail the re-creation of

[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&focusedCommentId=16709302#comment-16709302 ] ASF GitHub Bot commented on KAFKA-7660: --- mjsax closed pull request #5980: KAFKA-766

[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&focusedCommentId=16709296#comment-16709296 ] ASF GitHub Bot commented on KAFKA-7660: --- mjsax closed pull request #5979: KAFKA-766

[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&focusedCommentId=16709278#comment-16709278 ] Matthias J. Sax commented on KAFKA-7695: Thanks for the details. I would highly r

[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 delivery.timeout

[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&focusedCommentId=16709229#comment-16709229 ] Dmitry Buykin commented on KAFKA-7695: -- [~mjsax]   {quote}In our application we have

[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&focusedCommentId=16709173#comment-16709173 ] Matthias J. Sax commented on KAFKA-7699: {quote}would you want to epoch-align it

[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&focusedCommentId=16709166#comment-16709166 ] Matthias J. Sax commented on KAFKA-7695: I guess I was distracted by "global cons

[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&focusedCommentId=16709086#comment-16709086 ] Navinder Brar commented on KAFKA-6144: -- Is someone working on a patch for this? If I

[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 DumpLogSeg

[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&focusedCommentId=16708953#comment-16708953 ] John Roesler commented on KAFKA-7660: - Sounds good! We'll go ahead and leave this tic

[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&focusedCommentId=16708883#comment-16708883 ] John Roesler commented on KAFKA-7699: - Interesting thought! For anchored schedules, w

[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&focusedCommentId=16708719#comment-16708719 ] ASF GitHub Bot commented on KAFKA-7697: --- rajinisivaram opened a new pull request #5

[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&focusedCommentId=16708639#comment-16708639 ] Patrik Kleindl commented on KAFKA-7660: --- [~vvcephei] Will do so when we do the next

[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&focusedCommentId=16708633#comment-16708633 ] Attila Sasvari commented on KAFKA-7696: --- Thanks [~omkreddy]! Resolving this as a du

[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 > secur

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

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

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

[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 pr

[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&focusedCommentId=16708491#comment-16708491 ] Sebastian Puzoń commented on KAFKA-7531: Do you think this issue is related? Regu

[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&focusedCommentId=16708478#comment-16708478 ] ASF GitHub Bot commented on KAFKA-7702: --- rajinisivaram closed pull request #5994: K

[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&focusedCommentId=16708417#comment-16708417 ] Dmitry Buykin edited comment on KAFKA-7695 at 12/4/18 9:19 AM:

[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&focusedCommentId=16708417#comment-16708417 ] Dmitry Buykin edited comment on KAFKA-7695 at 12/4/18 9:13 AM:

[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&focusedCommentId=16708417#comment-16708417 ] Dmitry Buykin commented on KAFKA-7695: -- [~vvcephei] I'm agree with your comments. It

[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&focusedCommentId=16708392#comment-16708392 ] Dmitry Buykin edited comment on KAFKA-7695 at 12/4/18 8:40 AM:

[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&focusedCommentId=16708393#comment-16708393 ] Bo Wang commented on KAFKA-2729: I also got the same problem with 1.1.0, whether there is

[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&focusedCommentId=16708392#comment-16708392 ] Dmitry Buykin commented on KAFKA-7695: -- [~mjsax] I think it's a bug because KStreams