[jira] [Commented] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker

[ https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16987696#comment-16987696 ] Oleg Muravskiy commented on KAFKA-9173: --- [~ableegoldman] yes, I subscribe with a pa

[jira] [Commented] (KAFKA-9088) Consolidate InternalMockProcessorContext and MockInternalProcessorContext

[ https://issues.apache.org/jira/browse/KAFKA-9088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16987881#comment-16987881 ] Bruno Cadonna commented on KAFKA-9088: -- [~vvcephei] I have the following justificati

[jira] [Commented] (KAFKA-9265) kafka.log.Log instances are leaking on log delete

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

[jira] [Resolved] (KAFKA-9265) kafka.log.Log instances are leaking on log delete

[ https://issues.apache.org/jira/browse/KAFKA-9265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-9265. Fix Version/s: 2.3.2 2.4.0 Resolution: Fixed > kafka.log.Log instances ar

[jira] [Created] (KAFKA-9266) KafkaConsumer manual assignment does not reset group assignment

G G created KAFKA-9266: -- Summary: KafkaConsumer manual assignment does not reset group assignment Key: KAFKA-9266 URL: https://issues.apache.org/jira/browse/KAFKA-9266 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-9233) Kafka consumer throws undocumented IllegalStateException

[ https://issues.apache.org/jira/browse/KAFKA-9233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16987909#comment-16987909 ] Andrew Olson commented on KAFKA-9233: - [~hachikuji] Can you review this? > Kafka con

[jira] [Commented] (KAFKA-9195) Use Randomized State Directory Names in Streams System Tests

[ https://issues.apache.org/jira/browse/KAFKA-9195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16987922#comment-16987922 ] Bruno Cadonna commented on KAFKA-9195: -- I guess your proposal would also work. Howev

[jira] [Commented] (KAFKA-9225) kafka fail to run on linux-aarch64

[ https://issues.apache.org/jira/browse/KAFKA-9225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16987953#comment-16987953 ] John Roesler commented on KAFKA-9225: - When we discussed this before, we didn’t have

[jira] [Created] (KAFKA-9267) ZkSecurityMigrator should not create /controller node

NanerLee created KAFKA-9267: --- Summary: ZkSecurityMigrator should not create /controller node Key: KAFKA-9267 URL: https://issues.apache.org/jira/browse/KAFKA-9267 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-9267) ZkSecurityMigrator should not create /controller node

[ https://issues.apache.org/jira/browse/KAFKA-9267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] NanerLee updated KAFKA-9267: Description: As we can see in these source codes – [ZkSecurityMigrator.scala#L226|#L226]] _ZkSecurityMigra

[jira] [Commented] (KAFKA-7870) Error sending fetch request (sessionId=1578860481, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read.

[ https://issues.apache.org/jira/browse/KAFKA-7870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16987971#comment-16987971 ] jfc commented on KAFKA-7870: Same problem on 2.2.0-19 > Error sending fetch request (session

[jira] [Commented] (KAFKA-6793) Unnecessary warning log message

[ https://issues.apache.org/jira/browse/KAFKA-6793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16987977#comment-16987977 ] Alex Mironov commented on KAFKA-6793: - Hello [~mjsax], [~rhauch] — I'd like to bump u

[jira] [Commented] (KAFKA-9267) ZkSecurityMigrator should not create /controller node

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

[jira] [Updated] (KAFKA-9267) ZkSecurityMigrator should not create /controller node

[ https://issues.apache.org/jira/browse/KAFKA-9267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] NanerLee updated KAFKA-9267: External issue URL: https://github.com/apache/kafka/pull/7778 Description: As we can see in thes

[jira] [Updated] (KAFKA-9267) ZkSecurityMigrator should not create /controller node

[ https://issues.apache.org/jira/browse/KAFKA-9267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] NanerLee updated KAFKA-9267: External issue URL: (was: https://github.com/apache/kafka/pull/7778) > ZkSecurityMigrator should not crea

[jira] [Updated] (KAFKA-9267) ZkSecurityMigrator should not create /controller node

[ https://issues.apache.org/jira/browse/KAFKA-9267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] NanerLee updated KAFKA-9267: Reviewer: (was: NanerLee) > ZkSecurityMigrator should not create /controller node > -

[jira] [Commented] (KAFKA-9088) Consolidate InternalMockProcessorContext and MockInternalProcessorContext

[ https://issues.apache.org/jira/browse/KAFKA-9088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16987985#comment-16987985 ] John Roesler commented on KAFKA-9088: - Thanks for the justification, [~cadonna]. Sinc

[jira] [Created] (KAFKA-9268) Follow-on: Streams Threads may die from recoverable errors with EOS enabled

John Roesler created KAFKA-9268: --- Summary: Follow-on: Streams Threads may die from recoverable errors with EOS enabled Key: KAFKA-9268 URL: https://issues.apache.org/jira/browse/KAFKA-9268 Project: Kafk

[jira] [Updated] (KAFKA-9268) Follow-on: Streams Threads may die from recoverable errors with EOS enabled

[ https://issues.apache.org/jira/browse/KAFKA-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9268: Affects Version/s: (was: 2.4.0) 2.2.0 > Follow-on: Streams Threads may d

[jira] [Updated] (KAFKA-9268) Follow-on: Streams Threads may die from recoverable errors with EOS enabled

[ https://issues.apache.org/jira/browse/KAFKA-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9268: Priority: Major (was: Blocker) > Follow-on: Streams Threads may die from recoverable errors with E

[jira] [Commented] (KAFKA-9190) Server leaves connections with expired authentication sessions open

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

[jira] [Updated] (KAFKA-9268) Follow-on: Streams Threads may die from recoverable errors with EOS enabled

[ https://issues.apache.org/jira/browse/KAFKA-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9268: Description: While testing Streams in EOS mode under frequent and heavy network partitions, I've e

[jira] [Updated] (KAFKA-9268) Follow-on: Streams Threads may die from recoverable errors with EOS enabled

[ https://issues.apache.org/jira/browse/KAFKA-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9268: Attachment: 2.2-eos-failures-1.txt 2.2-eos-failures-2.txt > Follow-on: Streams Thre

[jira] [Updated] (KAFKA-9268) Follow-on: Streams Threads may die from recoverable errors with EOS enabled

[ https://issues.apache.org/jira/browse/KAFKA-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9268: Description: While testing Streams in EOS mode under frequent and heavy network partitions, I've e

[jira] [Assigned] (KAFKA-9268) Follow-on: Streams Threads may die from recoverable errors with EOS enabled

[ https://issues.apache.org/jira/browse/KAFKA-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-9268: --- Assignee: (was: John Roesler) > Follow-on: Streams Threads may die from recoverable erro

[jira] [Commented] (KAFKA-9231) Streams Threads may die from recoverable errors with EOS enabled

[ https://issues.apache.org/jira/browse/KAFKA-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16987992#comment-16987992 ] John Roesler commented on KAFKA-9231: - Opened https://issues.apache.org/jira/browse/K

[jira] [Commented] (KAFKA-9268) Follow-on: Streams Threads may die from recoverable errors with EOS enabled

[ https://issues.apache.org/jira/browse/KAFKA-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16988022#comment-16988022 ] Sophie Blee-Goldman commented on KAFKA-9268: Do you have any thoughts (or gue

[jira] [Resolved] (KAFKA-9190) Server leaves connections with expired authentication sessions open

[ https://issues.apache.org/jira/browse/KAFKA-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9190. Fix Version/s: 2.3.2 2.2.3 2.4.0 Resolution: Fi

[jira] [Commented] (KAFKA-9268) Follow-on: Streams Threads may die from recoverable errors with EOS enabled

[ https://issues.apache.org/jira/browse/KAFKA-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16988063#comment-16988063 ] Guozhang Wang commented on KAFKA-9268: -- [~ableegoldman] while reviewing the PR for K

[jira] [Assigned] (KAFKA-6266) Kafka 1.0.0 : Repeated occurrence of WARN Resetting first dirty offset of __consumer_offsets-xx to log start offset 203569 since the checkpointed offset 120955 is invali

[ https://issues.apache.org/jira/browse/KAFKA-6266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anna Povzner reassigned KAFKA-6266: --- Assignee: Anna Povzner > Kafka 1.0.0 : Repeated occurrence of WARN Resetting first dirty off

[jira] [Updated] (KAFKA-9268) Follow-on: Streams Threads may die from recoverable errors with EOS enabled

[ https://issues.apache.org/jira/browse/KAFKA-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-9268: - Fix Version/s: (was: 2.4.0) > Follow-on: Streams Threads may die from recoverable errors with EOS ena

[jira] [Commented] (KAFKA-9088) Consolidate InternalMockProcessorContext and MockInternalProcessorContext

[ https://issues.apache.org/jira/browse/KAFKA-9088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16988149#comment-16988149 ] Sophie Blee-Goldman commented on KAFKA-9088: I'm also fine with going ahead w

[jira] [Commented] (KAFKA-9173) StreamsPartitionAssignor assigns partitions to only one worker

[ https://issues.apache.org/jira/browse/KAFKA-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16988196#comment-16988196 ] Guozhang Wang commented on KAFKA-9173: -- [~o.muravskiy] Sorry that I did not make mys

[jira] [Commented] (KAFKA-9088) Consolidate InternalMockProcessorContext and MockInternalProcessorContext

[ https://issues.apache.org/jira/browse/KAFKA-9088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16988210#comment-16988210 ] Guozhang Wang commented on KAFKA-9088: -- Yeah I had similar experiences with [~ableeg

[jira] [Commented] (KAFKA-8933) An unhandled SSL handshake exception in polling event - needed a retry logic

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

[jira] [Commented] (KAFKA-9250) Kafka streams stuck in rebalancing state after UnknownHostException

[ https://issues.apache.org/jira/browse/KAFKA-9250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16988234#comment-16988234 ] Guozhang Wang commented on KAFKA-9250: -- [~vijay0309] Seems you are hitting https://

[jira] [Commented] (KAFKA-9251) Describing a non consumer group with the Admin API hangs forever

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

[jira] [Resolved] (KAFKA-9251) Describing a non consumer group with the Admin API hangs forever

[ https://issues.apache.org/jira/browse/KAFKA-9251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9251. Resolution: Fixed > Describing a non consumer group with the Admin API hangs forever >

[jira] [Updated] (KAFKA-9251) Describing a non consumer group with the Admin API hangs forever

[ https://issues.apache.org/jira/browse/KAFKA-9251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-9251: --- Fix Version/s: 2.3.1 2.4.0 > Describing a non consumer group with the Admi

[jira] [Updated] (KAFKA-9251) Describing a non consumer group with the Admin API hangs forever

[ https://issues.apache.org/jira/browse/KAFKA-9251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-9251: --- Affects Version/s: 2.3.0 > Describing a non consumer group with the Admin API hangs forever >

[jira] [Commented] (KAFKA-8904) Reduce metadata lookups when producing to a large number of topics

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

[jira] [Commented] (KAFKA-8933) An unhandled SSL handshake exception in polling event - needed a retry logic

[ https://issues.apache.org/jira/browse/KAFKA-8933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16988269#comment-16988269 ] Jason Gustafson commented on KAFKA-8933: We merged a fix for this issue to trunk,

[jira] [Commented] (KAFKA-9184) Redundant task creation and periodic rebalances after zombie worker rejoins the group

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

[jira] [Updated] (KAFKA-9219) NullPointerException when polling metrics from Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-9219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9219: - Fix Version/s: 2.4.0 > NullPointerException when polling metrics from Kafka Connect > ---

[jira] [Commented] (KAFKA-9219) NullPointerException when polling metrics from Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-9219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16988303#comment-16988303 ] Randall Hauch commented on KAFKA-9219: -- Although this PR was not backported to the `

[jira] [Commented] (KAFKA-9184) Redundant task creation and periodic rebalances after zombie worker rejoins the group

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

[jira] [Created] (KAFKA-9269) Warn if security.protocol does not match security configuration

Richard Wise created KAFKA-9269: --- Summary: Warn if security.protocol does not match security configuration Key: KAFKA-9269 URL: https://issues.apache.org/jira/browse/KAFKA-9269 Project: Kafka

[jira] [Commented] (KAFKA-9184) Redundant task creation and periodic rebalances after zombie worker rejoins the group

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

[jira] [Resolved] (KAFKA-9184) Redundant task creation and periodic rebalances after zombie worker rejoins the group

[ https://issues.apache.org/jira/browse/KAFKA-9184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-9184. -- Reviewer: Randall Hauch Resolution: Fixed > Redundant task creation and periodic rebalanc

[jira] [Updated] (KAFKA-9184) Redundant task creation and periodic rebalances after zombie worker rejoins the group

[ https://issues.apache.org/jira/browse/KAFKA-9184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9184: - Fix Version/s: 2.5.0 > Redundant task creation and periodic rebalances after zombie worker rejoin

[jira] [Commented] (KAFKA-9241) SASL Clients are not forced to re-authenticate if they don't leverage SaslAuthenticateRequest

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

[jira] [Updated] (KAFKA-9123) Add system test with large number of partitions

[ https://issues.apache.org/jira/browse/KAFKA-9123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-9123: - Fix Version/s: (was: 2.5.0) 2.4.0 > Add system test with large number of partition

[jira] [Resolved] (KAFKA-9123) Add system test with large number of partitions

[ https://issues.apache.org/jira/browse/KAFKA-9123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-9123. -- Resolution: Fixed > Add system test with large number of partitions > -

[jira] [Updated] (KAFKA-9267) ZkSecurityMigrator should not create /controller node

[ https://issues.apache.org/jira/browse/KAFKA-9267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] NanerLee updated KAFKA-9267: Reviewer: Manikumar > ZkSecurityMigrator should not create /controller node > -

[jira] [Commented] (KAFKA-9268) Follow-on: Streams Threads may die from recoverable errors with EOS enabled

[ https://issues.apache.org/jira/browse/KAFKA-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16988460#comment-16988460 ] Ismael Juma commented on KAFKA-9268: Is there any reason why people would not upgrade

[jira] [Created] (KAFKA-9270) KafkaStream crash on offset commit failure

Rohan Kulkarni created KAFKA-9270: - Summary: KafkaStream crash on offset commit failure Key: KAFKA-9270 URL: https://issues.apache.org/jira/browse/KAFKA-9270 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-9267) ZkSecurityMigrator should not create /controller node

[ https://issues.apache.org/jira/browse/KAFKA-9267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] NanerLee updated KAFKA-9267: Flags: Patch,Important (was: Important) > ZkSecurityMigrator should not create /controller node >

[jira] [Updated] (KAFKA-9270) KafkaStream crash on offset commit failure

[ https://issues.apache.org/jira/browse/KAFKA-9270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rohan Kulkarni updated KAFKA-9270: -- Description: On our Production server we intermittently observe Kafka Streams get crashed with

[jira] [Commented] (KAFKA-7982) ConcurrentModificationException and Continuous warnings "Attempting to send response via channel for which there is no open connection"

[ https://issues.apache.org/jira/browse/KAFKA-7982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16988520#comment-16988520 ] Pradeep Bansal commented on KAFKA-7982: --- This is affecting my setup as well. Is the

[jira] [Commented] (KAFKA-7925) Constant 100% cpu usage by all kafka brokers

[ https://issues.apache.org/jira/browse/KAFKA-7925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16988524#comment-16988524 ] Pradeep Bansal commented on KAFKA-7925: --- Is there any update. Seems like 2.3.0 and