[jira] [Resolved] (KAFKA-8351) Log cleaner must handle transactions spanning multiple segments

[ https://issues.apache.org/jira/browse/KAFKA-8351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8351. Resolution: Fixed Fix Version/s: 2.2.2 2.3.0 > Log cleaner must h

[jira] [Commented] (KAFKA-8351) Log cleaner must handle transactions spanning multiple segments

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

[jira] [Commented] (KAFKA-8428) Cleanup LogValidator#validateMessagesAndAssignOffsetsCompressed to assume single record batch only

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

[jira] [Resolved] (KAFKA-8422) Client should not use old versions of OffsetsForLeaderEpoch

[ https://issues.apache.org/jira/browse/KAFKA-8422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-8422. Resolution: Fixed > Client should not use old versions of OffsetsForLeaderEpoch > -

[jira] [Commented] (KAFKA-8422) Client should not use old versions of OffsetsForLeaderEpoch

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

[jira] [Created] (KAFKA-8430) Unit test to make sure `group.id` and `group.instance.id` won't affect each other

Boyang Chen created KAFKA-8430: -- Summary: Unit test to make sure `group.id` and `group.instance.id` won't affect each other Key: KAFKA-8430 URL: https://issues.apache.org/jira/browse/KAFKA-8430 Project:

[jira] [Commented] (KAFKA-8356) Add static membership to Round Robin assignor

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

[jira] [Assigned] (KAFKA-8356) Add static membership to Round Robin assignor

[ https://issues.apache.org/jira/browse/KAFKA-8356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-8356: -- Assignee: Boyang Chen > Add static membership to Round Robin assignor > --

[jira] [Commented] (KAFKA-8400) Do not update follower replica state if the log read failed

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

[jira] [Resolved] (KAFKA-8341) AdminClient should retry coordinator lookup after NOT_COORDINATOR error

[ https://issues.apache.org/jira/browse/KAFKA-8341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vikas Singh resolved KAFKA-8341. Resolution: Fixed fixed in commit 46a02f3231cd6d340c622636159b9f59b4b3cb6e > AdminClient should re

[jira] [Commented] (KAFKA-8341) AdminClient should retry coordinator lookup after NOT_COORDINATOR error

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

[jira] [Commented] (KAFKA-6830) Add new metrics for consumer/replication fetch requests

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

[jira] [Created] (KAFKA-8429) Consumer should handle offset change while OffsetForLeaderEpoch is inflight

Jason Gustafson created KAFKA-8429: -- Summary: Consumer should handle offset change while OffsetForLeaderEpoch is inflight Key: KAFKA-8429 URL: https://issues.apache.org/jira/browse/KAFKA-8429 Project

[jira] [Created] (KAFKA-8428) Cleanup LogValidator#validateMessagesAndAssignOffsetsCompressed to assume single record batch only

Guozhang Wang created KAFKA-8428: Summary: Cleanup LogValidator#validateMessagesAndAssignOffsetsCompressed to assume single record batch only Key: KAFKA-8428 URL: https://issues.apache.org/jira/browse/KAFKA-8428

[jira] [Commented] (KAFKA-7540) Flaky Test ConsumerBounceTest#testClose

[ https://issues.apache.org/jira/browse/KAFKA-7540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847825#comment-16847825 ] Matthias J. Sax commented on KAFKA-7540: One more:  [https://builds.apache.org/jo

[jira] [Assigned] (KAFKA-8412) Still a nullpointer exception thrown on shutdown while flushing before closing producers

[ https://issues.apache.org/jira/browse/KAFKA-8412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8412: -- Assignee: Matthias J. Sax > Still a nullpointer exception thrown on shutdown while flu

[jira] [Assigned] (KAFKA-8423) Update ducktape to not use deprecated APIs

[ https://issues.apache.org/jira/browse/KAFKA-8423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hardik Tewari reassigned KAFKA-8423: Assignee: Hardik Tewari > Update ducktape to not use deprecated APIs > ---

[jira] [Commented] (KAFKA-8423) Update ducktape to not use deprecated APIs

[ https://issues.apache.org/jira/browse/KAFKA-8423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847786#comment-16847786 ] Matthias J. Sax commented on KAFKA-8423: Sure. I added you to the list on contrib

[jira] [Commented] (KAFKA-8423) Update ducktape to not use deprecated APIs

[ https://issues.apache.org/jira/browse/KAFKA-8423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847780#comment-16847780 ] Hardik Tewari commented on KAFKA-8423: -- [~mjsax], I would like to give it a try. I a

[jira] [Commented] (KAFKA-8367) Non-heap memory leak in Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-8367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847768#comment-16847768 ] Pavel Savov commented on KAFKA-8367: Below are dumps of our topologies:   TOPOLOGY

[jira] [Commented] (KAFKA-8412) Still a nullpointer exception thrown on shutdown while flushing before closing producers

[ https://issues.apache.org/jira/browse/KAFKA-8412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847746#comment-16847746 ] Guozhang Wang commented on KAFKA-8412: -- [~mjsax] I looked through the code and the o

[jira] [Updated] (KAFKA-8427) Error while cleanup under windows for EmbeddedKafkaCluster

[ https://issues.apache.org/jira/browse/KAFKA-8427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sukumaar Mane updated KAFKA-8427: - Description: Unable to run a simple test case for EmbeddedKafkaCluster where there is an object

[jira] [Updated] (KAFKA-8427) Error while cleanup under windows for EmbeddedKafkaCluster

[ https://issues.apache.org/jira/browse/KAFKA-8427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sukumaar Mane updated KAFKA-8427: - Summary: Error while cleanup under windows for EmbeddedKafkaCluster (was: error while cleanup un

[jira] [Updated] (KAFKA-8427) error while cleanup under windows for EmbeddedKafkaCluster

[ https://issues.apache.org/jira/browse/KAFKA-8427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sukumaar Mane updated KAFKA-8427: - Description: Unable to run a simple test case for EmbeddedKafkaCluster. Running below simple cod

[jira] [Created] (KAFKA-8427) error while cleanup under windows for EmbeddedKafkaCluster

Sukumaar Mane created KAFKA-8427: Summary: error while cleanup under windows for EmbeddedKafkaCluster Key: KAFKA-8427 URL: https://issues.apache.org/jira/browse/KAFKA-8427 Project: Kafka Issu

[jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847632#comment-16847632 ] Ryanne Dolan commented on KAFKA-7500: - [~Munamala] thanks for trying it out! > The t

[jira] [Created] (KAFKA-8426) KIP 421 Bug: ConfigProvider configs param inconsistent with KIP-297

TEJAL ADSUL created KAFKA-8426: -- Summary: KIP 421 Bug: ConfigProvider configs param inconsistent with KIP-297 Key: KAFKA-8426 URL: https://issues.apache.org/jira/browse/KAFKA-8426 Project: Kafka

[jira] [Created] (KAFKA-8425) KIP 421 Bug: Modifying Immutable Originals Map results in Java exception

TEJAL ADSUL created KAFKA-8425: -- Summary: KIP 421 Bug: Modifying Immutable Originals Map results in Java exception Key: KAFKA-8425 URL: https://issues.apache.org/jira/browse/KAFKA-8425 Project: Kafka

[jira] [Updated] (KAFKA-8412) Still a nullpointer exception thrown on shutdown while flushing before closing producers

[ https://issues.apache.org/jira/browse/KAFKA-8412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-8412: - Labels: triaged (was: ) > Still a nullpointer exception thrown on shutdown while flushing before

[jira] [Updated] (KAFKA-8412) Still a nullpointer exception thrown on shutdown while flushing before closing producers

[ https://issues.apache.org/jira/browse/KAFKA-8412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-8412: - Labels: (was: triaged) > Still a nullpointer exception thrown on shutdown while flushing before

[jira] [Commented] (KAFKA-5345) Some socket connections not closed after restart of Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-5345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847429#comment-16847429 ] qianmoQ commented on KAFKA-5345: kakfa 0.10.0 has this bug, generating process: The data

[jira] [Issue Comment Deleted] (KAFKA-7245) Deprecate WindowStore#put(key, value)

[ https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Omkar Mestry updated KAFKA-7245: Comment: was deleted (was: Please provide permission for the username :- omanges on Confluence so

[jira] [Commented] (KAFKA-7245) Deprecate WindowStore#put(key, value)

[ https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847373#comment-16847373 ] Omkar Mestry commented on KAFKA-7245: - Please provide permission for the username :- 

[jira] [Assigned] (KAFKA-8342) Admin tool to setup Kafka Stream topology (internal) topics

[ https://issues.apache.org/jira/browse/KAFKA-8342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] WooYoung reassigned KAFKA-8342: --- Assignee: WooYoung > Admin tool to setup Kafka Stream topology (internal) topics > -

[jira] [Commented] (KAFKA-8422) Client should not use old versions of OffsetsForLeaderEpoch

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