[jira] [Commented] (KAFKA-6522) Retrying leaderEpoch request for partition xxx as the leader reported an error: UNKNOWN_SERVER_ERROR

[ https://issues.apache.org/jira/browse/KAFKA-6522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712214#comment-16712214 ] Sravan Meruva commented on KAFKA-6522: -- [~bookxiao], Is this issue resolved for you

[jira] [Commented] (KAFKA-6522) Retrying leaderEpoch request for partition xxx as the leader reported an error: UNKNOWN_SERVER_ERROR

[ https://issues.apache.org/jira/browse/KAFKA-6522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712213#comment-16712213 ] Sravan Meruva commented on KAFKA-6522: -- [~huxi_2b], We are facing a smiliar problem.

[jira] [Resolved] (KAFKA-7709) ConcurrentModificationException occurs when iterating through multiple partitions in Sender.getExpiredInflightBatches

[ https://issues.apache.org/jira/browse/KAFKA-7709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7709. -- Resolution: Fixed Fix Version/s: 2.1.1 2.2.0 Thanks [~markcho] for yo

[jira] [Commented] (KAFKA-7709) ConcurrentModificationException occurs when iterating through multiple partitions in Sender.getExpiredInflightBatches

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

[jira] [Commented] (KAFKA-7321) ensure timely processing of deletion requests in Kafka topic (Time-based log compaction)

[ https://issues.apache.org/jira/browse/KAFKA-7321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712085#comment-16712085 ] ASF GitHub Bot commented on KAFKA-7321: --- xiowu0 opened a new pull request #6009: KA

[jira] [Commented] (KAFKA-7321) ensure timely processing of deletion requests in Kafka topic (Time-based log compaction)

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

[jira] [Commented] (KAFKA-3450) Producer blocks on send to topic that doesn't exist if auto create is disabled

[ https://issues.apache.org/jira/browse/KAFKA-3450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16712077#comment-16712077 ] Aleksandar Nikolic commented on KAFKA-3450: --- Hi [~tu...@avast.com],  Same prob

[jira] [Created] (KAFKA-7711) Add a bounded flush() API to Kafka Producer

kun du created KAFKA-7711: - Summary: Add a bounded flush() API to Kafka Producer Key: KAFKA-7711 URL: https://issues.apache.org/jira/browse/KAFKA-7711 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-5061) client.id should be set for Connect producers/consumers

[ https://issues.apache.org/jira/browse/KAFKA-5061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16711912#comment-16711912 ] Paul Davidson commented on KAFKA-5061: -- I updated PR [https://github.com/apache/kafk

[jira] [Updated] (KAFKA-6388) Error while trying to roll a segment that already exists

[ https://issues.apache.org/jira/browse/KAFKA-6388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-6388: --- Fix Version/s: 1.1.2 > Error while trying to roll a segment that already exists > ---

[jira] [Commented] (KAFKA-7181) Kafka Streams State stuck in rebalancing after one of the StreamThread encounters IllegalStateException

[ https://issues.apache.org/jira/browse/KAFKA-7181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16711850#comment-16711850 ] Guozhang Wang commented on KAFKA-7181: -- I think this may be related to https://issue

[jira] [Commented] (KAFKA-7657) Invalid reporting of stream state in Kafka streams application

[ https://issues.apache.org/jira/browse/KAFKA-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16711839#comment-16711839 ] Guozhang Wang commented on KAFKA-7657: -- [~pkleindl] I think I've spotted the root ca

[jira] [Commented] (KAFKA-6388) Error while trying to roll a segment that already exists

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

[jira] [Commented] (KAFKA-7631) NullPointerException when SCRAM is allowed bu ScramLoginModule is not in broker's jaas.conf

[ https://issues.apache.org/jira/browse/KAFKA-7631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16711771#comment-16711771 ] Andras Beni commented on KAFKA-7631: [~mrsrinivas] none that I know of > NullPointer

[jira] [Commented] (KAFKA-7631) NullPointerException when SCRAM is allowed bu ScramLoginModule is not in broker's jaas.conf

[ https://issues.apache.org/jira/browse/KAFKA-7631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16711730#comment-16711730 ] Srinivas Reddy commented on KAFKA-7631: --- [~andrasbeni], [~asasvari]: is there any u

[jira] [Resolved] (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:all-tabpanel ] Jun Rao resolved KAFKA-7704. Resolution: Fixed Fix Version/s: 2.1.1 2.2.0 Merged to trunk and 2.1. > kafka.se

[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=16711463#comment-16711463 ] ASF GitHub Bot commented on KAFKA-7704: --- junrao closed pull request #5998: KAFKA-77

[jira] [Commented] (KAFKA-7657) Invalid reporting of stream state in Kafka streams application

[ https://issues.apache.org/jira/browse/KAFKA-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16711247#comment-16711247 ] Patrik Kleindl commented on KAFKA-7657: --- [~guozhang]   {code:java} 2018-11-30 08:5

[jira] [Commented] (KAFKA-7703) KafkaConsumer.position may return a wrong offset after "seekToEnd" is called

[ https://issues.apache.org/jira/browse/KAFKA-7703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16711191#comment-16711191 ] Shixiong Zhu commented on KAFKA-7703: - [~viktorsomogyi] Cool! Thanks! Let me know if