[jira] [Commented] (KAFKA-7425) Kafka Broker -Unable to start

[ https://issues.apache.org/jira/browse/KAFKA-7425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16902627#comment-16902627 ] Sathish Yanamala commented on KAFKA-7425: - Hello Manikumar,   Can you please he

[jira] [Commented] (KAFKA-7508) Kafka broker anonymous disconnected from Zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-7508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16902626#comment-16902626 ] Sathish Yanamala commented on KAFKA-7508: - Hello Santill/Manikumar,   Can you p

[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=16902554#comment-16902554 ] ASF GitHub Bot commented on KAFKA-6958: --- mjsax commented on pull request #5909: KAF

[jira] [Updated] (KAFKA-8602) StreamThread Dies Because Restore Consumer is not Subscribed to Any Topic

[ https://issues.apache.org/jira/browse/KAFKA-8602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8602: --- Fix Version/s: 2.0.2 > StreamThread Dies Because Restore Consumer is not Subscribed to Any To

[jira] [Commented] (KAFKA-8602) StreamThread Dies Because Restore Consumer is not Subscribed to Any Topic

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

[jira] [Commented] (KAFKA-8736) Performance: ThreadCache uses size() for empty cache check

[ https://issues.apache.org/jira/browse/KAFKA-8736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16902544#comment-16902544 ] Matthias J. Sax commented on KAFKA-8736: My last comment is incorrect. This is a

[jira] [Updated] (KAFKA-8736) Performance: ThreadCache uses size() for empty cache check

[ https://issues.apache.org/jira/browse/KAFKA-8736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8736: --- Priority: Critical (was: Major) > Performance: ThreadCache uses size() for empty cache check

[jira] [Updated] (KAFKA-8736) Performance: ThreadCache uses size() for empty cache check

[ https://issues.apache.org/jira/browse/KAFKA-8736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8736: --- Issue Type: Bug (was: Improvement) > Performance: ThreadCache uses size() for empty cache ch

[jira] [Updated] (KAFKA-8736) Performance: ThreadCache uses size() for empty cache check

[ https://issues.apache.org/jira/browse/KAFKA-8736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8736: --- Description: While load testing Kafka Streams in 2.3.0, we stumbled across a potential perfo

[jira] [Updated] (KAFKA-8736) Performance: ThreadCache uses size() for empty cache check

[ https://issues.apache.org/jira/browse/KAFKA-8736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8736: --- Affects Version/s: (was: 0.10.1.0) 2.3.0 > Performance: ThreadCach

[jira] [Updated] (KAFKA-8736) Performance: ThreadCache uses size() for empty cache check

[ https://issues.apache.org/jira/browse/KAFKA-8736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8736: --- Fix Version/s: (was: 2.2.2) (was: 2.1.2) (wa

[jira] [Created] (KAFKA-8767) Optimize StickyAssignor for Cooperative mode

Sophie Blee-Goldman created KAFKA-8767: -- Summary: Optimize StickyAssignor for Cooperative mode Key: KAFKA-8767 URL: https://issues.apache.org/jira/browse/KAFKA-8767 Project: Kafka Issue

[jira] [Commented] (KAFKA-8325) Remove from the incomplete set failed. This should be impossible

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

[jira] [Created] (KAFKA-8766) Allow a custom offset policy for Kafka Streams applications

Patrik Kleindl created KAFKA-8766: - Summary: Allow a custom offset policy for Kafka Streams applications Key: KAFKA-8766 URL: https://issues.apache.org/jira/browse/KAFKA-8766 Project: Kafka

[jira] [Assigned] (KAFKA-7335) Store clusterId locally to ensure broker joins the right cluster

[ https://issues.apache.org/jira/browse/KAFKA-7335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot reassigned KAFKA-7335: -- Assignee: David Jacot > Store clusterId locally to ensure broker joins the right cluster > ---

[jira] [Commented] (KAFKA-8522) Tombstones can survive forever

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

[jira] [Commented] (KAFKA-8765) Remove "unstable" annotations

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

[jira] [Commented] (KAFKA-7656) ReplicaManager fetch fails on leader due to long/integer overflow

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

[jira] [Created] (KAFKA-8765) Remove "unstable" annotations

Matthias J. Sax created KAFKA-8765: -- Summary: Remove "unstable" annotations Key: KAFKA-8765 URL: https://issues.apache.org/jira/browse/KAFKA-8765 Project: Kafka Issue Type: Task Co

[jira] [Assigned] (KAFKA-8765) Remove "unstable" annotations

[ https://issues.apache.org/jira/browse/KAFKA-8765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8765: -- Assignee: Matthias J. Sax > Remove "unstable" annotations > --

[jira] [Commented] (KAFKA-8522) Tombstones can survive forever

[ https://issues.apache.org/jira/browse/KAFKA-8522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16902334#comment-16902334 ] Jun Rao commented on KAFKA-8522: [~Yohan123], I was thinking of adding a new checkpoint f

[jira] [Commented] (KAFKA-8716) broker cannot join the cluster after upgrading kafka binary from 2.1.1 to 2.2.1 or 2.3.0

[ https://issues.apache.org/jira/browse/KAFKA-8716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16902324#comment-16902324 ] Jun Rao commented on KAFKA-8716: [~yuyang08], thanks for the update. > broker cannot joi

[jira] [Resolved] (KAFKA-8716) broker cannot join the cluster after upgrading kafka binary from 2.1.1 to 2.2.1 or 2.3.0

[ https://issues.apache.org/jira/browse/KAFKA-8716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Yang resolved KAFKA-8716. Resolution: Not A Problem > broker cannot join the cluster after upgrading kafka binary from 2.1.1 to > 2.

[jira] [Commented] (KAFKA-8716) broker cannot join the cluster after upgrading kafka binary from 2.1.1 to 2.2.1 or 2.3.0

[ https://issues.apache.org/jira/browse/KAFKA-8716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16902255#comment-16902255 ] Yu Yang commented on KAFKA-8716: Update: We verified that after upgrading zookeeper to 3.

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16902231#comment-16902231 ] Matthias J. Sax commented on KAFKA-7965: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-8748) Flaky Test DescribeLogDirsRequestTest#testDescribeLogDirsRequest

[ https://issues.apache.org/jira/browse/KAFKA-8748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16902232#comment-16902232 ] Matthias J. Sax commented on KAFKA-8748: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-8677) Flakey test GroupEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

[ https://issues.apache.org/jira/browse/KAFKA-8677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16902230#comment-16902230 ] Matthias J. Sax commented on KAFKA-8677: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-8522) Tombstones can survive forever

[ https://issues.apache.org/jira/browse/KAFKA-8522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16902209#comment-16902209 ] Richard Yu commented on KAFKA-8522: --- [~junrao] You mentioned in a previous post that we

[jira] [Updated] (KAFKA-8602) StreamThread Dies Because Restore Consumer is not Subscribed to Any Topic

[ https://issues.apache.org/jira/browse/KAFKA-8602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8602: --- Fix Version/s: 1.1.2 > StreamThread Dies Because Restore Consumer is not Subscribed to Any To

[jira] [Commented] (KAFKA-8602) StreamThread Dies Because Restore Consumer is not Subscribed to Any Topic

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

[jira] [Updated] (KAFKA-8764) LogCleanerManager endless loop while compacting/cleaning segments

[ https://issues.apache.org/jira/browse/KAFKA-8764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tomislav Rajakovic updated KAFKA-8764: -- Affects Version/s: 2.3.0 > LogCleanerManager endless loop while compacting/cleaning seg

[jira] [Created] (KAFKA-8764) LogCleanerManager endless loop while compacting/cleaning segments

Tomislav Rajakovic created KAFKA-8764: - Summary: LogCleanerManager endless loop while compacting/cleaning segments Key: KAFKA-8764 URL: https://issues.apache.org/jira/browse/KAFKA-8764 Project: Ka

[jira] [Resolved] (KAFKA-8599) Replace ExpireDelegationToken request/response with automated protocol

[ https://issues.apache.org/jira/browse/KAFKA-8599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-8599. -- Resolution: Fixed Fix Version/s: 2.4.0 Issue resolved by pull request 7098 [https://github.com/a

[jira] [Commented] (KAFKA-5876) IQ should throw different exceptions for different errors

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