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
[
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.
[
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!
[
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
[
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:
[
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()`.
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
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
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
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:
[
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
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
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
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
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
[
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
[
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,
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
[
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
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
[
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
[
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:
[
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
[
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
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
[
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
[
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
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
[
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?
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
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
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
32 matches
Mail list logo