[jira] [Commented] (KAFKA-6542) Tables should trigger joins too, not just streams

[ https://issues.apache.org/jira/browse/KAFKA-6542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964651#comment-16964651 ] Matthias J. Sax commented on KAFKA-6542: KTables are not really bootstrapped -- c

[jira] [Updated] (KAFKA-9127) Needless group coordination overhead for GlobalKTables

[ https://issues.apache.org/jira/browse/KAFKA-9127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9127: --- Affects Version/s: (was: 2.3.0) 0.10.2.0 > Needless group coordina

[jira] [Commented] (KAFKA-9073) Kafka Streams State stuck in rebalancing after one of the StreamThread encounters java.lang.IllegalStateException: No current assignment for partition

[ https://issues.apache.org/jira/browse/KAFKA-9073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964576#comment-16964576 ] Guozhang Wang commented on KAFKA-9073: -- [~simplyamuthan] You can find the explanatio

[jira] [Resolved] (KAFKA-9114) Kafka broker fails to establish secure zookeeper connection via SSL.

[ https://issues.apache.org/jira/browse/KAFKA-9114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gangadhar Balikai resolved KAFKA-9114. -- Resolution: Invalid > Kafka broker fails to establish secure zookeeper connection via S

[jira] [Commented] (KAFKA-9114) Kafka broker fails to establish secure zookeeper connection via SSL.

[ https://issues.apache.org/jira/browse/KAFKA-9114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964570#comment-16964570 ] Gangadhar Balikai commented on KAFKA-9114: -- found issue on my side. > Kafka bro

[jira] [Created] (KAFKA-9127) Needless group coordination overhead for GlobalKTables

Chris Toomey created KAFKA-9127: --- Summary: Needless group coordination overhead for GlobalKTables Key: KAFKA-9127 URL: https://issues.apache.org/jira/browse/KAFKA-9127 Project: Kafka Issue Type

[jira] [Resolved] (KAFKA-9093) NullPointerException in KafkaConsumer with group.instance.id

[ https://issues.apache.org/jira/browse/KAFKA-9093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx resolved KAFKA-9093. --- Resolution: Fixed > NullPointerException in KafkaConsumer with group.instance.id > --

[jira] [Commented] (KAFKA-9073) Kafka Streams State stuck in rebalancing after one of the StreamThread encounters java.lang.IllegalStateException: No current assignment for partition

[ https://issues.apache.org/jira/browse/KAFKA-9073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964526#comment-16964526 ] amuthan Ganeshan commented on KAFKA-9073: - I am more interested in understanding

[jira] [Commented] (KAFKA-9073) Kafka Streams State stuck in rebalancing after one of the StreamThread encounters java.lang.IllegalStateException: No current assignment for partition

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

[jira] [Commented] (KAFKA-8972) KafkaConsumer.unsubscribe could leave inconsistent user rebalance callback state

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

[jira] [Commented] (KAFKA-9113) Clean up task management

[ https://issues.apache.org/jira/browse/KAFKA-9113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964468#comment-16964468 ] Guozhang Wang commented on KAFKA-9113: -- Also related to the above call: we should re

[jira] [Commented] (KAFKA-9113) Clean up task management

[ https://issues.apache.org/jira/browse/KAFKA-9113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964462#comment-16964462 ] Guozhang Wang commented on KAFKA-9113: -- Dumping my thoughts here: for closing as zom

[jira] [Resolved] (KAFKA-9073) Kafka Streams State stuck in rebalancing after one of the StreamThread encounters java.lang.IllegalStateException: No current assignment for partition

[ https://issues.apache.org/jira/browse/KAFKA-9073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-9073. -- Resolution: Fixed > Kafka Streams State stuck in rebalancing after one of the StreamThread > e

[jira] [Commented] (KAFKA-9073) Kafka Streams State stuck in rebalancing after one of the StreamThread encounters java.lang.IllegalStateException: No current assignment for partition

[ https://issues.apache.org/jira/browse/KAFKA-9073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964437#comment-16964437 ] Guozhang Wang commented on KAFKA-9073: -- We can resolve this as fixed in 2.4.0 only f

[jira] [Commented] (KAFKA-9073) Kafka Streams State stuck in rebalancing after one of the StreamThread encounters java.lang.IllegalStateException: No current assignment for partition

[ https://issues.apache.org/jira/browse/KAFKA-9073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964436#comment-16964436 ] Matthias J. Sax commented on KAFKA-9073: [~simplyamuthan] [~ableegoldman] [~guozh

[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=16964422#comment-16964422 ] Sophie Blee-Goldman commented on KAFKA-9088: It's still pretty awkward to mak

[jira] [Commented] (KAFKA-9072) Add Section to Streams Developer Guide for Topology Naming (KIP-307)

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

[jira] [Updated] (KAFKA-9113) Clean up task management

[ https://issues.apache.org/jira/browse/KAFKA-9113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9113: --- Description: Along KIP-429 we did a lot of refactoring of the task management classes

[jira] [Commented] (KAFKA-9080) System Test Failure: MessageFormatChangeTest.testCompatibilty

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

[jira] [Commented] (KAFKA-8737) TaskMigrated Exception while rebalancing kafka streams

[ https://issues.apache.org/jira/browse/KAFKA-8737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964410#comment-16964410 ] KUMAR commented on KAFKA-8737: -- Hi Bill Is there a plan to fix this issue similar to earlier

[jira] [Updated] (KAFKA-8558) KIP-479 - Add StreamJoined Overload to KStream#Join

[ https://issues.apache.org/jira/browse/KAFKA-8558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8558: --- Description: To prevent a topology incompatibility with the release of 2.4 and the naming of

[jira] [Created] (KAFKA-9126) Extend `StreamJoined` to allow more store configs

Matthias J. Sax created KAFKA-9126: -- Summary: Extend `StreamJoined` to allow more store configs Key: KAFKA-9126 URL: https://issues.apache.org/jira/browse/KAFKA-9126 Project: Kafka Issue Typ

[jira] [Updated] (KAFKA-8558) KIP-479 - Add StreamJoined Overload to KStream#Join

[ https://issues.apache.org/jira/browse/KAFKA-8558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8558: --- Labels: kip (was: needs-kip) > KIP-479 - Add StreamJoined Overload to KStream#Join > --

[jira] [Updated] (KAFKA-8558) KIP-479 - Add StreamJoined Overload to KStream#Join

[ https://issues.apache.org/jira/browse/KAFKA-8558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8558: --- Summary: KIP-479 - Add StreamJoined Overload to KStream#Join (was: KIP-479 - Add Materializ

[jira] [Commented] (KAFKA-9073) Kafka Streams State stuck in rebalancing after one of the StreamThread encounters java.lang.IllegalStateException: No current assignment for partition

[ https://issues.apache.org/jira/browse/KAFKA-9073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964218#comment-16964218 ] Guozhang Wang commented on KAFKA-9073: -- Thanks for the find-out, I can prepare a PR

[jira] [Created] (KAFKA-9125) GroupMetadataManager and TransactionStateManager should use metadata cache instead of zkClient

Viktor Somogyi-Vass created KAFKA-9125: -- Summary: GroupMetadataManager and TransactionStateManager should use metadata cache instead of zkClient Key: KAFKA-9125 URL: https://issues.apache.org/jira/browse/KAFK

[jira] [Issue Comment Deleted] (KAFKA-9124) ISR changes should be propagated via Kafka protocol

[ https://issues.apache.org/jira/browse/KAFKA-9124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Viktor Somogyi-Vass updated KAFKA-9124: --- Comment: was deleted (was: Opened by mistake.) > ISR changes should be propagated vi

[jira] [Updated] (KAFKA-9124) ISR changes should be propagated via Kafka protocol

[ https://issues.apache.org/jira/browse/KAFKA-9124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Viktor Somogyi-Vass updated KAFKA-9124: --- Description: Currently {{Partition.expandIsr}} and {{Partition.shrinkIsr}} updates Zo

[jira] [Updated] (KAFKA-9124) ISR changes should be propagated via Kafka protocol

[ https://issues.apache.org/jira/browse/KAFKA-9124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Viktor Somogyi-Vass updated KAFKA-9124: --- Description: Currently {{Partition.expandIsr}} and {{Partition.shrinkIsr}} updates Zo

[jira] [Reopened] (KAFKA-9124) Topic creation should be done by the controller

[ https://issues.apache.org/jira/browse/KAFKA-9124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Viktor Somogyi-Vass reopened KAFKA-9124: > Topic creation should be done by the controller > ---

[jira] [Updated] (KAFKA-9124) ISR changes should be propagated via Kafka protocol

[ https://issues.apache.org/jira/browse/KAFKA-9124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Viktor Somogyi-Vass updated KAFKA-9124: --- Summary: ISR changes should be propagated via Kafka protocol (was: Topic creation sh

[jira] [Resolved] (KAFKA-9124) Topic creation should be done by the controller

[ https://issues.apache.org/jira/browse/KAFKA-9124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Viktor Somogyi-Vass resolved KAFKA-9124. Resolution: Invalid Opened by mistake. > Topic creation should be done by the cont

[jira] [Created] (KAFKA-9124) Topic creation should be done by the controller

Viktor Somogyi-Vass created KAFKA-9124: -- Summary: Topic creation should be done by the controller Key: KAFKA-9124 URL: https://issues.apache.org/jira/browse/KAFKA-9124 Project: Kafka Iss

[jira] [Commented] (KAFKA-9122) Externalizing DB password is not working

[ https://issues.apache.org/jira/browse/KAFKA-9122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964122#comment-16964122 ] Dwijadas commented on KAFKA-9122: - Hi After removing the quotes from the credential file,

[jira] [Commented] (KAFKA-9122) Externalizing DB password is not working

[ https://issues.apache.org/jira/browse/KAFKA-9122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964095#comment-16964095 ] Dwijadas commented on KAFKA-9122: - In the distributed connector log, i can see value of u

[jira] [Updated] (KAFKA-9122) Externalizing DB password is not working

[ https://issues.apache.org/jira/browse/KAFKA-9122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dwijadas updated KAFKA-9122: Attachment: Screenshot_1.png > Externalizing DB password is not working > -

[jira] [Commented] (KAFKA-9121) Mirror Maker 2.0 doesn't handle the topic names in consumer checkpoints properly when topic name contain separator

[ https://issues.apache.org/jira/browse/KAFKA-9121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964089#comment-16964089 ] Jakub Scholz commented on KAFKA-9121: - I wondered if the alias of the source/target c

[jira] [Commented] (KAFKA-9120) Convert ./bin/kafka-reassign-partitions.sh to use KIP-455

[ https://issues.apache.org/jira/browse/KAFKA-9120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964077#comment-16964077 ] Stanislav Kozlovski commented on KAFKA-9120: This is tracked in https://issue

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=16964017#comment-16964017 ] ASF GitHub Bot commented on KAFKA-9123: --- mumrah commented on pull request #7621: KA

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

David Arthur created KAFKA-9123: --- Summary: Add system test with large number of partitions Key: KAFKA-9123 URL: https://issues.apache.org/jira/browse/KAFKA-9123 Project: Kafka Issue Type: Test

[jira] [Commented] (KAFKA-6542) Tables should trigger joins too, not just streams

[ https://issues.apache.org/jira/browse/KAFKA-6542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963970#comment-16963970 ] Chad Preisler commented on KAFKA-6542: -- [~mjsax] Thank you for the clarification. I

[jira] [Commented] (KAFKA-9034) kafka-run-class.sh will fail if JAVA_HOME has space

[ https://issues.apache.org/jira/browse/KAFKA-9034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963923#comment-16963923 ] Xu JianHai commented on KAFKA-9034: --- new intellij java use "_" replace wiith blank spac

[jira] [Assigned] (KAFKA-9034) kafka-run-class.sh will fail if JAVA_HOME has space

[ https://issues.apache.org/jira/browse/KAFKA-9034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu JianHai reassigned KAFKA-9034: - Assignee: (was: Xu JianHai) > kafka-run-class.sh will fail if JAVA_HOME has space >

[jira] [Created] (KAFKA-9122) Externalizing DB password is not working

Dwijadas created KAFKA-9122: --- Summary: Externalizing DB password is not working Key: KAFKA-9122 URL: https://issues.apache.org/jira/browse/KAFKA-9122 Project: Kafka Issue Type: Bug Compon

[jira] [Commented] (KAFKA-8769) Consider computing stream time independently per key

[ https://issues.apache.org/jira/browse/KAFKA-8769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963785#comment-16963785 ] Matthias J. Sax commented on KAFKA-8769: I did not ready the KIP yet, but I perso

[jira] [Commented] (KAFKA-6542) Tables should trigger joins too, not just streams

[ https://issues.apache.org/jira/browse/KAFKA-6542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963776#comment-16963776 ] Matthias J. Sax commented on KAFKA-6542: [~cpreisler], it's unfortunately not tha

[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=16963757#comment-16963757 ] Matthias J. Sax commented on KAFKA-9088: [~ableegoldman] I have no objections – a