[GitHub] [kafka] RivenSun2 commented on pull request #11340: KAFKA-13310 : KafkaConsumer cannot jump out of the poll method, and the…

2021-12-28 Thread GitBox
RivenSun2 commented on pull request #11340: URL: https://github.com/apache/kafka/pull/11340#issuecomment-1001976302 @showuon Sorry, I analyzed it carefully, because in the `ConsumerCoordinator#close(timer)` method, we changed to call `maybeAutoCommitOffsetsAsync()`, so the following

[jira] [Commented] (KAFKA-13437) Broker parameter optimization: security.inter.broker.protocol and num.network.threads

2021-12-28 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466055#comment-17466055 ] RivenSun commented on KAFKA-13437: -- Hi [~guozhang] , [~showuon] can you give any suggestions? Thanks.

[jira] [Commented] (KAFKA-13406) Cooperative sticky assignor got stuck due to assignment validation failed

2021-12-28 Thread Juhyeon Kim (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466002#comment-17466002 ] Juhyeon Kim commented on KAFKA-13406: - [~showuon], thank you very much for your quick answer!

[jira] [Commented] (KAFKA-13463) Improvement: KafkaConsumer pause(Collection partitions)

2021-12-28 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466010#comment-17466010 ] RivenSun commented on KAFKA-13463: -- [~ableegoldman]  [~guozhang] [~showuon]  Do you have any

[jira] [Commented] (KAFKA-13406) Cooperative sticky assignor got stuck due to assignment validation failed

2021-12-28 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466104#comment-17466104 ] Luke Chen commented on KAFKA-13406: --- v3.1.0 was planned to be released in Dec. 2021 based on the plan:

[jira] [Commented] (KAFKA-13563) Consumer failure after rolling Broker upgrade

2021-12-28 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465999#comment-17465999 ] Luke Chen commented on KAFKA-13563: --- [~jim_b_o] , this issue is because of using `consumer#assign()`.

[GitHub] [kafka] RivenSun2 commented on pull request #11340: KAFKA-13310 : KafkaConsumer cannot jump out of the poll method, and the…

2021-12-28 Thread GitBox
RivenSun2 commented on pull request #11340: URL: https://github.com/apache/kafka/pull/11340#issuecomment-1001943022 Hi @showuon I checked out a new branch `trunk_for_uptodate` from my `trunk` branch, and pulled the latest code of `apache:trunk` Using Gradle 7.2, Java 11 and

[jira] [Created] (KAFKA-13569) Is changing a message / field name a breaking change?

2021-12-28 Thread Fredrik Arvidsson (Jira)
Fredrik Arvidsson created KAFKA-13569: - Summary: Is changing a message / field name a breaking change? Key: KAFKA-13569 URL: https://issues.apache.org/jira/browse/KAFKA-13569 Project: Kafka

[GitHub] [kafka] showuon commented on a change in pull request #11340: KAFKA-13310 : KafkaConsumer cannot jump out of the poll method, and the…

2021-12-28 Thread GitBox
showuon commented on a change in pull request #11340: URL: https://github.com/apache/kafka/pull/11340#discussion_r775889114 ## File path: clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java ## @@ -2230,7 +2230,7 @@ public void

[GitHub] [kafka] showuon commented on pull request #11340: KAFKA-13310 : KafkaConsumer cannot jump out of the poll method, and the…

2021-12-28 Thread GitBox
showuon commented on pull request #11340: URL: https://github.com/apache/kafka/pull/11340#issuecomment-1002083565 @RivenSun2 , thanks for the fix. The test ran successfully now! From the test results, there is a failed test: `testCloseManualAssignment`. Please fix it. Thanks. REF:

[jira] [Commented] (KAFKA-13422) Even if the correct username and password are configured, when ClientBroker or KafkaClient tries to establish a SASL connection to ServerBroker, an exception is thrown

2021-12-28 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466057#comment-17466057 ] RivenSun commented on KAFKA-13422: -- Hi [~rsivaram]  [~ijuma] , [~guozhang]  can you give any

[GitHub] [kafka] kkonstantine commented on a change in pull request #11619: MINOR: allocate 2MB to offset map in connect EmbeddedKafkaCluster

2021-12-28 Thread GitBox
kkonstantine commented on a change in pull request #11619: URL: https://github.com/apache/kafka/pull/11619#discussion_r776089831 ## File path: connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedKafkaCluster.java ## @@ -135,6 +135,8 @@ private void

[jira] [Created] (KAFKA-13570) Fallback of unsupported versions of ApiVersionsRequest and RequestHeader?

2021-12-28 Thread Fredrik Arvidsson (Jira)
Fredrik Arvidsson created KAFKA-13570: - Summary: Fallback of unsupported versions of ApiVersionsRequest and RequestHeader? Key: KAFKA-13570 URL: https://issues.apache.org/jira/browse/KAFKA-13570

[GitHub] [kafka] RivenSun2 commented on a change in pull request #11340: KAFKA-13310 : KafkaConsumer cannot jump out of the poll method, and the…

2021-12-28 Thread GitBox
RivenSun2 commented on a change in pull request #11340: URL: https://github.com/apache/kafka/pull/11340#discussion_r775930900 ## File path: clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java ## @@ -2230,7 +2230,7 @@ public void

[GitHub] [kafka] RivenSun2 commented on a change in pull request #11340: KAFKA-13310 : KafkaConsumer cannot jump out of the poll method, and the…

2021-12-28 Thread GitBox
RivenSun2 commented on a change in pull request #11340: URL: https://github.com/apache/kafka/pull/11340#discussion_r775942935 ## File path: clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java ## @@ -2230,7 +2230,7 @@ public void

[jira] [Commented] (KAFKA-13406) Cooperative sticky assignor got stuck due to assignment validation failed

2021-12-28 Thread Juhyeon Kim (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466284#comment-17466284 ] Juhyeon Kim commented on KAFKA-13406: - [~showuon], Thank you for sharing it :) > Cooperative sticky

[jira] [Commented] (KAFKA-13564) Kafka keep print NOT_LEADER_OR_FOLLOWER in log file after one broker dropped, and the producer can not work.

2021-12-28 Thread ZhenChun Pan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466299#comment-17466299 ] ZhenChun Pan commented on KAFKA-13564: -- There is no error can find in state change logs like below,

[GitHub] [kafka] lbradstreet commented on a change in pull request #11619: MINOR: allocate 2MB to offset map in connect EmbeddedKafkaCluster

2021-12-28 Thread GitBox
lbradstreet commented on a change in pull request #11619: URL: https://github.com/apache/kafka/pull/11619#discussion_r776132997 ## File path: connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedKafkaCluster.java ## @@ -135,6 +135,8 @@ private void

[jira] [Updated] (KAFKA-13571) Enabling MirrorMaker 2.0 with TLS

2021-12-28 Thread Bharath Reddy (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Reddy updated KAFKA-13571: -- Description: Hi All,   We are trying to enableTLS for MirrorMaker

[jira] [Created] (KAFKA-13571) Enabling MirrorMaker 2.0 with TLS

2021-12-28 Thread Bharath Reddy (Jira)
Bharath Reddy created KAFKA-13571: - Summary: Enabling MirrorMaker 2.0 with TLS Key: KAFKA-13571 URL: https://issues.apache.org/jira/browse/KAFKA-13571 Project: Kafka Issue Type: Task

[jira] [Updated] (KAFKA-13524) IQv2: Implement KeyQuery from the RecordCache

2021-12-28 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13524: - Summary: IQv2: Implement KeyQuery from the RecordCache (was: IQv2: Add option for KeyQuery

[jira] [Updated] (KAFKA-13524) IQv2: Add option for KeyQuery from caches

2021-12-28 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13524: - Description: I did a quick POC of this:

[jira] [Updated] (KAFKA-13524) IQv2: Add option for KeyQuery from caches

2021-12-28 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13524: - Summary: IQv2: Add option for KeyQuery from caches (was: IQv2: Add option to query KV Stores

[jira] [Updated] (KAFKA-13524) IQv2: Add option for KeyQuery from the RecordCache

2021-12-28 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13524: - Summary: IQv2: Add option for KeyQuery from the RecordCache (was: IQv2: Add option for

[GitHub] [kafka] showuon commented on a change in pull request #11340: KAFKA-13310 : KafkaConsumer cannot jump out of the poll method, and the…

2021-12-28 Thread GitBox
showuon commented on a change in pull request #11340: URL: https://github.com/apache/kafka/pull/11340#discussion_r776176434 ## File path: clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinatorTest.java ## @@ -3202,17 +3202,18 @@ private void

[jira] [Commented] (KAFKA-13569) Is changing a message / field name a breaking change?

2021-12-28 Thread dengziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466288#comment-17466288 ] dengziming commented on KAFKA-13569: Currently the json schema is indeed not public api, A KIP will

[jira] [Updated] (KAFKA-13524) IQv2: Implement KeyQuery from the RecordCache

2021-12-28 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-13524: - Description: The Record Cache in Kafka Streams is more properly termed a write buffer, since

[GitHub] [kafka] lbradstreet commented on a change in pull request #11619: MINOR: allocate 2MB to offset map in connect EmbeddedKafkaCluster

2021-12-28 Thread GitBox
lbradstreet commented on a change in pull request #11619: URL: https://github.com/apache/kafka/pull/11619#discussion_r776117981 ## File path: connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedKafkaCluster.java ## @@ -135,6 +135,8 @@ private void

[jira] [Commented] (KAFKA-12495) Unbalanced connectors/tasks distribution will happen in Connect's incremental cooperative assignor

2021-12-28 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466296#comment-17466296 ] Luke Chen commented on KAFKA-12495: --- [~kkonstantine] , could you give some suggestion for the issue? 

[GitHub] [kafka] RivenSun2 commented on a change in pull request #11340: KAFKA-13310 : KafkaConsumer cannot jump out of the poll method, and the…

2021-12-28 Thread GitBox
RivenSun2 commented on a change in pull request #11340: URL: https://github.com/apache/kafka/pull/11340#discussion_r776189676 ## File path: clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinatorTest.java ## @@ -3202,17 +3202,18 @@ private void

[GitHub] [kafka] RivenSun2 commented on a change in pull request #11340: KAFKA-13310 : KafkaConsumer cannot jump out of the poll method, and the…

2021-12-28 Thread GitBox
RivenSun2 commented on a change in pull request #11340: URL: https://github.com/apache/kafka/pull/11340#discussion_r776189676 ## File path: clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinatorTest.java ## @@ -3202,17 +3202,18 @@ private void

[GitHub] [kafka] RivenSun2 commented on a change in pull request #11340: KAFKA-13310 : KafkaConsumer cannot jump out of the poll method, and the…

2021-12-28 Thread GitBox
RivenSun2 commented on a change in pull request #11340: URL: https://github.com/apache/kafka/pull/11340#discussion_r776189676 ## File path: clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinatorTest.java ## @@ -3202,17 +3202,18 @@ private void