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

2022-02-10 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490722#comment-17490722 ] RivenSun commented on KAFKA-13463: -- [~guozhang]  [~showuon2]  Thanks for your reply, I also agree with

[jira] [Updated] (KAFKA-1935) Consumer should use a separate socket for Coordinator connection

2022-02-10 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-1935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1935: - Labels: new-rebalance-should-fix newbie (was: new-consumer-threading-should-fix newbie) >

[jira] [Updated] (KAFKA-1935) Consumer should use a separate socket for Coordinator connection

2022-02-10 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-1935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1935: - Labels: new-consumer-threading-should-fix newbie (was: newbie) > Consumer should use a separate

[jira] [Updated] (KAFKA-4740) Using new consumer API with a Deserializer that throws SerializationException can lead to infinite loop

2022-02-10 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4740: - Labels: new-consumer-threading-should-fix (was: ) > Using new consumer API with a Deserializer

[jira] [Updated] (KAFKA-3949) Consumer topic subscription change may be ignored if a rebalance is in progress

2022-02-10 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-3949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3949: - Labels: new-consumer-threading-should-fix (was: ) > Consumer topic subscription change may be

[jira] [Updated] (KAFKA-2168) New consumer poll() can block other calls like position(), commit(), and close() indefinitely

2022-02-10 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2168: - Labels: new-consumer-threading-should-fix (was: ) > New consumer poll() can block other calls

[jira] [Updated] (KAFKA-9140) Consumer gets stuck rejoining the group indefinitely

2022-02-10 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-9140: - Labels: new-consumer-threading-should-fix (was: ) > Consumer gets stuck rejoining the group

[jira] [Updated] (KAFKA-8104) Consumer cannot rejoin to the group after rebalancing

2022-02-10 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8104: - Labels: new-consumer-threading-should-fix (was: ) > Consumer cannot rejoin to the group after

[jira] [Updated] (KAFKA-12169) Consumer can not know paritions change when client leader restart with static membership protocol

2022-02-10 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-12169: -- Labels: bug new-rebalance-should-fix (was: bug) > Consumer can not know paritions change

[jira] [Commented] (KAFKA-12169) Consumer can not know paritions change when client leader restart with static membership protocol

2022-02-10 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490715#comment-17490715 ] Guozhang Wang commented on KAFKA-12169: --- This seems related to KAFKA-13543 as well. > Consumer

[jira] [Updated] (KAFKA-10793) Race condition in FindCoordinatorFuture permanently severs connection to group coordinator

2022-02-10 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-10793: -- Labels: new-consumer-threading-should-fix (was: ) > Race condition in FindCoordinatorFuture

[jira] [Updated] (KAFKA-13425) KafkaConsumer#pause() will lose its effect after groupRebalance occurs, which maybe cause data loss on the consumer side

2022-02-10 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-13425: -- Labels: new-consumer-threading-should-fix (was: ) > KafkaConsumer#pause() will lose its

[jira] [Updated] (KAFKA-13563) FindCoordinatorFuture never get cleared in non-group mode( consumer#assign)

2022-02-10 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-13563: -- Labels: new-consumer-threading-should-fix (was: ) > FindCoordinatorFuture never get cleared

[jira] [Updated] (KAFKA-12256) auto commit causes delays due to retriable UNKNOWN_TOPIC_OR_PARTITION

2022-02-10 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-12256: -- Labels: new-consumer-threading-should-fix (was: ) > auto commit causes delays due to

[jira] [Updated] (KAFKA-7109) KafkaConsumer should close its incremental fetch sessions on close

2022-02-10 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-7109: - Labels: new-consumer-threading-should-fix (was: ) > KafkaConsumer should close its incremental

[jira] [Updated] (KAFKA-13310) KafkaConsumer cannot jump out of the poll method, and the consumer is blocked in the ConsumerCoordinator method maybeAutoCommitOffsetsSync(Timer timer). Cpu and traffic

2022-02-10 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-13310: -- Labels: new-consumer-threading-should-fix (was: new-rebalance-should-fix) > KafkaConsumer

[jira] [Updated] (KAFKA-13322) Java client produces a large amount of garbage during a poll

2022-02-10 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-13322: -- Labels: new-consumer-threading-should-fix (was: new-rebalance-should-fix) > Java client

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

2022-02-10 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-13463: -- Labels: new-consumer-threading-should-fix (was: new-rebalance-should-fix) > Improvement:

[jira] [Updated] (KAFKA-13435) Group won't consume partitions added after static member restart

2022-02-10 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-13435: -- Labels: new-rebalance-should-fix (was: ) > Group won't consume partitions added after static

[GitHub] [kafka] dengziming commented on a change in pull request #11667: MINOR; Enable Kraft in ApiVersionTest

2022-02-10 Thread GitBox
dengziming commented on a change in pull request #11667: URL: https://github.com/apache/kafka/pull/11667#discussion_r804400933 ## File path: core/src/test/scala/unit/kafka/server/AbstractApiVersionsRequestTest.scala ## @@ -59,15 +68,40 @@ abstract class

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

2022-02-10 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490704#comment-17490704 ] Guozhang Wang commented on KAFKA-13463: --- Thanks for brining this up [~RivenSun]. Just to bring

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

2022-02-10 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-13463: -- Labels: new-rebalance-should-fix (was: ) > Improvement: KafkaConsumer pause(Collection

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

2022-02-10 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490696#comment-17490696 ] Luke Chen commented on KAFKA-13463: --- [~RivenSun] , thanks for reporting this. Sorry for the delay.

[GitHub] [kafka] dengziming commented on pull request #11141: KAFKA-13142: Validate dynamic config alterations prior to forwarding them to the KRaft controller.

2022-02-10 Thread GitBox
dengziming commented on pull request #11141: URL: https://github.com/apache/kafka/pull/11141#issuecomment-1035919472 It seems this has beed fixed in https://issues.apache.org/jira/browse/KAFKA-13552 -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [kafka] showuon commented on a change in pull request #11616: MINOR: update the description in Kraft example properties file

2022-02-10 Thread GitBox
showuon commented on a change in pull request #11616: URL: https://github.com/apache/kafka/pull/11616#discussion_r804339452 ## File path: config/kraft/server.properties ## @@ -31,22 +31,23 @@ controller.quorum.voters=1@localhost:9093 # Socket

[GitHub] [kafka] vvcephei commented on pull request #11534: KAFKA-12939: After migrating processors, search the codebase for missed migrations

2022-02-10 Thread GitBox
vvcephei commented on pull request #11534: URL: https://github.com/apache/kafka/pull/11534#issuecomment-1035857317 I'm kicking off one more run to see if it will be clean(er): https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-11534/7/ -- This is an automated message from the

[GitHub] [kafka] vvcephei commented on pull request #11534: KAFKA-12939: After migrating processors, search the codebase for missed migrations

2022-02-10 Thread GitBox
vvcephei commented on pull request #11534: URL: https://github.com/apache/kafka/pull/11534#issuecomment-1035856587 There were quite a few test failures: ``` [Build / JDK 17 and Scala 2.13 /

[GitHub] [kafka] showuon commented on a change in pull request #11616: MINOR: update the description in Kraft example properties file

2022-02-10 Thread GitBox
showuon commented on a change in pull request #11616: URL: https://github.com/apache/kafka/pull/11616#discussion_r804339452 ## File path: config/kraft/server.properties ## @@ -31,22 +31,23 @@ controller.quorum.voters=1@localhost:9093 # Socket

[GitHub] [kafka] dengziming commented on a change in pull request #11746: MINOR: Use timeout config in KafkaAdminClient

2022-02-10 Thread GitBox
dengziming commented on a change in pull request #11746: URL: https://github.com/apache/kafka/pull/11746#discussion_r804334534 ## File path: clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java ## @@ -524,7 +524,7 @@ static KafkaAdminClient

[jira] [Created] (KAFKA-13665) Null pointer exception testPollReturnsNoRecords

2022-02-10 Thread Alyssa Huang (Jira)
Alyssa Huang created KAFKA-13665: Summary: Null pointer exception testPollReturnsNoRecords Key: KAFKA-13665 URL: https://issues.apache.org/jira/browse/KAFKA-13665 Project: Kafka Issue Type:

[GitHub] [kafka] vamossagar12 commented on a change in pull request #11424: KAFKA-13152: Replace "buffered.records.per.partition" with "input.buffer.max.bytes"

2022-02-10 Thread GitBox
vamossagar12 commented on a change in pull request #11424: URL: https://github.com/apache/kafka/pull/11424#discussion_r804307612 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/TopologyConfig.java ## @@ -116,14 +123,30 @@ public

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

2022-02-10 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490615#comment-17490615 ] RivenSun edited comment on KAFKA-13463 at 2/11/22, 1:50 AM: [~ableegoldman]  

[GitHub] [kafka] vamossagar12 commented on pull request #11433: KAFKA-13295: Avoiding Transation timeouts arising due to long restora…

2022-02-10 Thread GitBox
vamossagar12 commented on pull request #11433: URL: https://github.com/apache/kafka/pull/11433#issuecomment-1035711101 @ableegoldman . do you think this one is in a good shape? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [kafka] vamossagar12 commented on pull request #11424: KAFKA-13152: Replace "buffered.records.per.partition" with "input.buffer.max.bytes"

2022-02-10 Thread GitBox
vamossagar12 commented on pull request #11424: URL: https://github.com/apache/kafka/pull/11424#issuecomment-1035710771 @mjsax not yet.. I couldn't find the time yet to pick this up. Would send an update soon. -- This is an automated message from the Apache Git Service. To respond to the

[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

2022-02-10 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490622#comment-17490622 ] RivenSun commented on KAFKA-13422: -- [~guozhang] Thank you for your reply [~rsivaram]  [~ijuma] could

[GitHub] [kafka] vamossagar12 commented on pull request #10798: KAFKA-9168: Adding direct byte buffer support to rocksdb state store

2022-02-10 Thread GitBox
vamossagar12 commented on pull request #10798: URL: https://github.com/apache/kafka/pull/10798#issuecomment-1035710408 @cadonna , done. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[jira] [Resolved] (KAFKA-9168) Integrate JNI direct buffer support to RocksDBStore

2022-02-10 Thread Sagar Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sagar Rao resolved KAFKA-9168. -- Resolution: Later This would be taken up once we have a more complete solution > Integrate JNI direct

[GitHub] [kafka] vamossagar12 closed pull request #10798: KAFKA-9168: Adding direct byte buffer support to rocksdb state store

2022-02-10 Thread GitBox
vamossagar12 closed pull request #10798: URL: https://github.com/apache/kafka/pull/10798 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Commented] (KAFKA-13663) IllegalMonitorStateException in ProducerMetadata.awaitUpdate

2022-02-10 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490620#comment-17490620 ] RivenSun commented on KAFKA-13663: -- [~ijuma]  Thank you for your reply Upgrading the JDK version may

[jira] [Commented] (KAFKA-13576) Processor.ConnectionQueueSize provides configuration & metrics, SelectorMetrics adds connection-register related metrics

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

[jira] [Commented] (KAFKA-13663) IllegalMonitorStateException in ProducerMetadata.awaitUpdate

2022-02-10 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490616#comment-17490616 ] Ismael Juma commented on KAFKA-13663: - Can you please try with the latest version of a Java version

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

2022-02-10 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490615#comment-17490615 ] RivenSun commented on KAFKA-13463: -- [~ableegoldman]  [~guozhang] [~showuon] [~lukebooxnote]  Could you

[jira] [Commented] (KAFKA-13663) IllegalMonitorStateException in ProducerMetadata.awaitUpdate

2022-02-10 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490612#comment-17490612 ] RivenSun commented on KAFKA-13663: -- [~lukebooxnote] Thank you for your reply I agree with you, it's

[GitHub] [kafka] junrao commented on a change in pull request #11390: [KAFKA-13369] Follower fetch protocol changes for tiered storage.

2022-02-10 Thread GitBox
junrao commented on a change in pull request #11390: URL: https://github.com/apache/kafka/pull/11390#discussion_r804020896 ## File path: core/src/main/scala/kafka/server/AbstractFetcherThread.scala ## @@ -90,18 +90,42 @@ abstract class AbstractFetcherThread(name: String,

[GitHub] [kafka] mdedetrich commented on pull request #11478: KAFKA-13299: Accept duplicate listener on port for IPv4/IPv6

2022-02-10 Thread GitBox
mdedetrich commented on pull request #11478: URL: https://github.com/apache/kafka/pull/11478#issuecomment-1035687499 I have rebased the PR against the latest Kafka trunk -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [kafka] hachikuji commented on a change in pull request #11616: MINOR: update the description in Kraft example properties file

2022-02-10 Thread GitBox
hachikuji commented on a change in pull request #11616: URL: https://github.com/apache/kafka/pull/11616#discussion_r804270026 ## File path: config/kraft/server.properties ## @@ -31,22 +31,23 @@ controller.quorum.voters=1@localhost:9093 # Socket

[GitHub] [kafka] hachikuji commented on a change in pull request #11667: MINOR; Enable Kraft in ApiVersionTest

2022-02-10 Thread GitBox
hachikuji commented on a change in pull request #11667: URL: https://github.com/apache/kafka/pull/11667#discussion_r804266771 ## File path: core/src/test/scala/unit/kafka/server/AbstractApiVersionsRequestTest.scala ## @@ -59,15 +68,40 @@ abstract class

[GitHub] [kafka] artemlivshits commented on a change in pull request #11688: KAFKA-13435; Static membership protocol should let the leader skip assignment (KIP-814)

2022-02-10 Thread GitBox
artemlivshits commented on a change in pull request #11688: URL: https://github.com/apache/kafka/pull/11688#discussion_r804264986 ## File path: connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinator.java ## @@ -211,7 +211,13 @@ protected

[jira] [Assigned] (KAFKA-13229) KIP-761: implement a total blocked time metric in Kafka Streams

2022-02-10 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-13229: --- Assignee: Rohan Desai > KIP-761: implement a total blocked time metric in Kafka

[GitHub] [kafka] hachikuji commented on a change in pull request #11688: KAFKA-13435; Static membership protocol should let the leader skip assignment (KIP-814)

2022-02-10 Thread GitBox
hachikuji commented on a change in pull request #11688: URL: https://github.com/apache/kafka/pull/11688#discussion_r804248978 ## File path: clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java ## @@ -699,11 +702,15 @@ public void

[GitHub] [kafka] hachikuji commented on a change in pull request #11688: KAFKA-13435; Static membership protocol should let the leader skip assignment (KIP-814)

2022-02-10 Thread GitBox
hachikuji commented on a change in pull request #11688: URL: https://github.com/apache/kafka/pull/11688#discussion_r804247861 ## File path: connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinator.java ## @@ -211,7 +211,13 @@ protected void

[GitHub] [kafka] hachikuji commented on a change in pull request #11603: MINOR: MetadataShell should handle ProducerIdsRecord

2022-02-10 Thread GitBox
hachikuji commented on a change in pull request #11603: URL: https://github.com/apache/kafka/pull/11603#discussion_r804172617 ## File path: shell/src/main/java/org/apache/kafka/shell/MetadataNodeManager.java ## @@ -318,6 +320,16 @@ private void

[jira] [Resolved] (KAFKA-13323) The words are ambiguous

2022-02-10 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-13323. - Fix Version/s: 3.2.0 Resolution: Fixed > The words are ambiguous >

[GitHub] [kafka] hachikuji merged pull request #11558: KAFKA-13323 Fixed variable name in KafkaConsumer

2022-02-10 Thread GitBox
hachikuji merged pull request #11558: URL: https://github.com/apache/kafka/pull/11558 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Resolved] (KAFKA-13316) Convert CreateTopicsRequestWithPolicyTest to use ClusterTest

2022-02-10 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-13316. - Fix Version/s: 3.2.0 Assignee: dengziming Resolution: Fixed > Convert

[GitHub] [kafka] hachikuji merged pull request #11655: KAFKA-13316; Enable KRaft mode in CreateTopics tests

2022-02-10 Thread GitBox
hachikuji merged pull request #11655: URL: https://github.com/apache/kafka/pull/11655 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [kafka] hachikuji opened a new pull request #11747: MINOR: Clearer field names for ProducerIdsRecord and related classes

2022-02-10 Thread GitBox
hachikuji opened a new pull request #11747: URL: https://github.com/apache/kafka/pull/11747 I found the current naming of the fields a little confusing in regard to whether the block range was inclusive or exclusive. This patch tries to improve naming to make this clearer. ###

[GitHub] [kafka] mumrah commented on a change in pull request #11603: MINOR: MetadataShell should handle ProducerIdsRecord

2022-02-10 Thread GitBox
mumrah commented on a change in pull request #11603: URL: https://github.com/apache/kafka/pull/11603#discussion_r804057789 ## File path: shell/src/main/java/org/apache/kafka/shell/MetadataNodeManager.java ## @@ -318,6 +320,16 @@ private void handleCommitImpl(MetadataRecordType

[GitHub] [kafka] mjsax commented on pull request #11424: KAFKA-13152: Replace "buffered.records.per.partition" with "input.buffer.max.bytes"

2022-02-10 Thread GitBox
mjsax commented on pull request #11424: URL: https://github.com/apache/kafka/pull/11424#issuecomment-1035421559 @vamossagar12 -- Any update from your side about opening a new PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [kafka] hachikuji commented on pull request #11558: KAFKA-13323 Fixed variable name in KafkaConsumer

2022-02-10 Thread GitBox
hachikuji commented on pull request #11558: URL: https://github.com/apache/kafka/pull/11558#issuecomment-1035409532 I went ahead and reverted the unrelated change in `docs/streams/developer-guide/processor-api.html` so that we can get the easy name fix checked in. -- This is an

[GitHub] [kafka] hachikuji commented on a change in pull request #11603: MINOR: MetadataShell should handle ProducerIdsRecord

2022-02-10 Thread GitBox
hachikuji commented on a change in pull request #11603: URL: https://github.com/apache/kafka/pull/11603#discussion_r804018735 ## File path: shell/src/main/java/org/apache/kafka/shell/MetadataNodeManager.java ## @@ -318,6 +320,16 @@ private void

[jira] [Commented] (KAFKA-12635) Mirrormaker 2 offset sync is incorrect if the target partition is empty

2022-02-10 Thread Mickael Maison (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490408#comment-17490408 ] Mickael Maison commented on KAFKA-12635: Thinking about this further, one thing I missed

[GitHub] [kafka] hachikuji merged pull request #11546: Fix storage metadata comparison in storage tool

2022-02-10 Thread GitBox
hachikuji merged pull request #11546: URL: https://github.com/apache/kafka/pull/11546 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [kafka] mimaison commented on a change in pull request #11603: MINOR: MetadataShell should handle ProducerIdsRecord

2022-02-10 Thread GitBox
mimaison commented on a change in pull request #11603: URL: https://github.com/apache/kafka/pull/11603#discussion_r803938280 ## File path: shell/src/test/java/org/apache/kafka/shell/MetadataNodeManagerTest.java ## @@ -290,4 +293,47 @@ public void testClientQuotaRecord() {

[GitHub] [kafka] akatona84 commented on pull request #11565: KAFKA-13504: Retry connect internal topics' creation in case of InvalidReplicationFactorException

2022-02-10 Thread GitBox
akatona84 commented on pull request #11565: URL: https://github.com/apache/kafka/pull/11565#issuecomment-1035198133 > Thanks @akatona84 for the PR. In order to add new configurations, we need to have a [KIP](https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals)

[GitHub] [kafka] seanli-rallyhealth commented on a change in pull request #10265: [KAFKA-7718] KIP-634 implementation

2022-02-10 Thread GitBox
seanli-rallyhealth commented on a change in pull request #10265: URL: https://github.com/apache/kafka/pull/10265#discussion_r803917746 ## File path: streams/src/main/java/org/apache/kafka/streams/kstream/RecordValue.java ## @@ -34,6 +34,22 @@ final long timestamp;

[GitHub] [kafka] mimaison commented on pull request #11565: KAFKA-13504: Retry connect internal topics' creation in case of InvalidReplicationFactorException

2022-02-10 Thread GitBox
mimaison commented on pull request #11565: URL: https://github.com/apache/kafka/pull/11565#issuecomment-1035183468 Thanks @akatona84 for the PR. In order to add new configurations, we need to have a [KIP](https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals)

[GitHub] [kafka] OneCricketeer commented on a change in pull request #11746: MINOR: Use timeout config in KafkaAdminClient

2022-02-10 Thread GitBox
OneCricketeer commented on a change in pull request #11746: URL: https://github.com/apache/kafka/pull/11746#discussion_r803897385 ## File path: clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java ## @@ -524,7 +524,7 @@ static KafkaAdminClient

[GitHub] [kafka] mimaison closed pull request #4281: [WIP] KAFKA-5693 rationalise policy interfaces

2022-02-10 Thread GitBox
mimaison closed pull request #4281: URL: https://github.com/apache/kafka/pull/4281 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [kafka] mimaison commented on pull request #4281: [WIP] KAFKA-5693 rationalise policy interfaces

2022-02-10 Thread GitBox
mimaison commented on pull request #4281: URL: https://github.com/apache/kafka/pull/4281#issuecomment-1035154386 Since KIP-201 has been abandoned, I'm closing out this PR for now. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [kafka] mimaison closed pull request #3898: KAFKA-4320: Log cleaner is enabled by default

2022-02-10 Thread GitBox
mimaison closed pull request #3898: URL: https://github.com/apache/kafka/pull/3898 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [kafka] mimaison commented on pull request #3898: KAFKA-4320: Log cleaner is enabled by default

2022-02-10 Thread GitBox
mimaison commented on pull request #3898: URL: https://github.com/apache/kafka/pull/3898#issuecomment-1035147300 Since this PR was for the 0.9 docs, I think it can now be closed. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [kafka] mimaison commented on pull request #3899: KAFKA-4320: Log cleaner is enabled by default

2022-02-10 Thread GitBox
mimaison commented on pull request #3899: URL: https://github.com/apache/kafka/pull/3899#issuecomment-1035147071 Since this PR was for the 0.10 docs, I think it can now be closed. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [kafka] mimaison closed pull request #3899: KAFKA-4320: Log cleaner is enabled by default

2022-02-10 Thread GitBox
mimaison closed pull request #3899: URL: https://github.com/apache/kafka/pull/3899 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [kafka] mimaison closed pull request #4289: KAFKA-6301 changing regular expression in ops.html from '*' to '.*'

2022-02-10 Thread GitBox
mimaison closed pull request #4289: URL: https://github.com/apache/kafka/pull/4289 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [kafka] mimaison commented on pull request #4289: KAFKA-6301 changing regular expression in ops.html from '*' to '.*'

2022-02-10 Thread GitBox
mimaison commented on pull request #4289: URL: https://github.com/apache/kafka/pull/4289#issuecomment-1035142329 MirrorMaker is now deprecated and as this PR is stalled I'll close it out for now. -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [kafka] artemlivshits commented on a change in pull request #11688: KAFKA-13435; Static membership protocol should let the leader skip assignment (KIP-814)

2022-02-10 Thread GitBox
artemlivshits commented on a change in pull request #11688: URL: https://github.com/apache/kafka/pull/11688#discussion_r803873160 ## File path: connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinator.java ## @@ -211,7 +211,13 @@ protected

[jira] [Resolved] (KAFKA-13636) Committed offsets could be deleted during a rebalance if a group did not commit for a while

2022-02-10 Thread David Jacot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-13636. - Fix Version/s: 3.0.1 2.8.2 3.2.0 3.1.1

[GitHub] [kafka] dajac commented on pull request #11742: KAFKA-13636: Fix for the group coordinator issue where the offsets are deleted for unstable groups

2022-02-10 Thread GitBox
dajac commented on pull request #11742: URL: https://github.com/apache/kafka/pull/11742#issuecomment-1035138963 Merged to trunk, 3.1, 3.0 and 2.8. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [kafka] mimaison closed pull request #8930: Mirror Maker 2: offset-syncs variable

2022-02-10 Thread GitBox
mimaison closed pull request #8930: URL: https://github.com/apache/kafka/pull/8930 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [kafka] mimaison commented on pull request #8930: Mirror Maker 2: offset-syncs variable

2022-02-10 Thread GitBox
mimaison commented on pull request #8930: URL: https://github.com/apache/kafka/pull/8930#issuecomment-1035136857 I believe this has been addressed by

[GitHub] [kafka] mimaison commented on pull request #8862: Dev/t toacin/2 4 1 mirror maker

2022-02-10 Thread GitBox
mimaison commented on pull request #8862: URL: https://github.com/apache/kafka/pull/8862#issuecomment-1035132930 This PR is stalled so I'll close it out for now. Feel free to reopen if you want to restart working on it. -- This is an automated message from the Apache Git Service. To

[GitHub] [kafka] mimaison closed pull request #8862: Dev/t toacin/2 4 1 mirror maker

2022-02-10 Thread GitBox
mimaison closed pull request #8862: URL: https://github.com/apache/kafka/pull/8862 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [kafka] mimaison commented on pull request #1912: KAFKA-4201: Add an `assignment.strategy` option to new-consumer-based Mirror Maker

2022-02-10 Thread GitBox
mimaison commented on pull request #1912: URL: https://github.com/apache/kafka/pull/1912#issuecomment-1035130631 MirrorMaker is now deprecated and as this PR is stalled I'll close it out for now. -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [kafka] mimaison closed pull request #1912: KAFKA-4201: Add an `assignment.strategy` option to new-consumer-based Mirror Maker

2022-02-10 Thread GitBox
mimaison closed pull request #1912: URL: https://github.com/apache/kafka/pull/1912 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [kafka] mimaison closed pull request #2161: KAFKA-4307 Inconsistent parameters between console producer and consumer

2022-02-10 Thread GitBox
mimaison closed pull request #2161: URL: https://github.com/apache/kafka/pull/2161 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [kafka] mimaison commented on pull request #2161: KAFKA-4307 Inconsistent parameters between console producer and consumer

2022-02-10 Thread GitBox
mimaison commented on pull request #2161: URL: https://github.com/apache/kafka/pull/2161#issuecomment-1035125665 I believe this has been addressed by [KIP-499](https://cwiki.apache.org/confluence/display/KAFKA/KIP-499+-+Unify+connection+name+flag+for+command+line+tool), so closing this

[GitHub] [kafka] dajac merged pull request #11742: KAFKA-13636: Fix for the group coordinator issue where the offsets are deleted for unstable groups

2022-02-10 Thread GitBox
dajac merged pull request #11742: URL: https://github.com/apache/kafka/pull/11742 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [kafka] mimaison closed pull request #5902: Kafka_7615

2022-02-10 Thread GitBox
mimaison closed pull request #5902: URL: https://github.com/apache/kafka/pull/5902 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [kafka] mimaison commented on pull request #5902: Kafka_7615

2022-02-10 Thread GitBox
mimaison commented on pull request #5902: URL: https://github.com/apache/kafka/pull/5902#issuecomment-1035117402 MirrorMaker is now deprecated and as this PR is stalled I'll close it out for now. -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [kafka] mimaison commented on pull request #5935: KAFKA-7665: Replace BaseConsumerRecord with ConsumerRecord in MM

2022-02-10 Thread GitBox
mimaison commented on pull request #5935: URL: https://github.com/apache/kafka/pull/5935#issuecomment-1035117159 MirrorMaker is now deprecated and as this PR is stalled I'll close it out for now. -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [kafka] mimaison closed pull request #5935: KAFKA-7665: Replace BaseConsumerRecord with ConsumerRecord in MM

2022-02-10 Thread GitBox
mimaison closed pull request #5935: URL: https://github.com/apache/kafka/pull/5935 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [kafka] mimaison commented on pull request #2394: KAFKA-4668: Replicate mirrormaker topics from earliest

2022-02-10 Thread GitBox
mimaison commented on pull request #2394: URL: https://github.com/apache/kafka/pull/2394#issuecomment-1035116196 MirrorMaker is now deprecated and as this PR is stalled I'll close it out for now. -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [kafka] mimaison closed pull request #2394: KAFKA-4668: Replicate mirrormaker topics from earliest

2022-02-10 Thread GitBox
mimaison closed pull request #2394: URL: https://github.com/apache/kafka/pull/2394 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [kafka] mimaison closed pull request #6563: KAFKA-8226: New MirrorMaker option partition.to.partition

2022-02-10 Thread GitBox
mimaison closed pull request #6563: URL: https://github.com/apache/kafka/pull/6563 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [kafka] mimaison commented on pull request #6563: KAFKA-8226: New MirrorMaker option partition.to.partition

2022-02-10 Thread GitBox
mimaison commented on pull request #6563: URL: https://github.com/apache/kafka/pull/6563#issuecomment-1035115854 MirrorMaker is now deprecated and as this PR is stalled I'll close it out for now. -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [kafka] mimaison commented on pull request #3151: KAFKA-5331:MirrorMaker can't guarantee data is consistent between clusters

2022-02-10 Thread GitBox
mimaison commented on pull request #3151: URL: https://github.com/apache/kafka/pull/3151#issuecomment-1035115617 MirrorMaker is now deprecated and as this PR is stalled I'll close it out for now. -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [kafka] mimaison closed pull request #3151: KAFKA-5331:MirrorMaker can't guarantee data is consistent between clusters

2022-02-10 Thread GitBox
mimaison closed pull request #3151: URL: https://github.com/apache/kafka/pull/3151 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [kafka] mimaison commented on pull request #2665: MINOR: Let MirrorMaker pick up client.id if specified in consumer.properties

2022-02-10 Thread GitBox
mimaison commented on pull request #2665: URL: https://github.com/apache/kafka/pull/2665#issuecomment-1035114899 MirrorMaker is now deprecated and as this PR is stalled I'll close it out for now. -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [kafka] mimaison closed pull request #2665: MINOR: Let MirrorMaker pick up client.id if specified in consumer.properties

2022-02-10 Thread GitBox
mimaison closed pull request #2665: URL: https://github.com/apache/kafka/pull/2665 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

  1   2   >