[jira] [Assigned] (KAFKA-14311) Connect Worker clean shutdown does not cleanly stop connectors/tasks

2022-10-23 Thread Sagar Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sagar Rao reassigned KAFKA-14311: - Assignee: Sagar Rao > Connect Worker clean shutdown does not cleanly stop connectors/tasks > --

[GitHub] [kafka] OmniaGM commented on pull request #12366: KAFKA-14021: Implement new KIP-618 APIs in MirrorSourceConnector

2022-10-23 Thread GitBox
OmniaGM commented on PR #12366: URL: https://github.com/apache/kafka/pull/12366#issuecomment-1288227815 > @OmniaGM You've been active recently with MirrorMaker 2 and seem quite familiar with it. Would you be willing to give this a review? I'd love it if someone could fact-check here and mak

[GitHub] [kafka] C0urante commented on a diff in pull request #12561: KAFKA-12495: Exponential backoff retry to prevent rebalance storms when worker joins after revoking rebalance

2022-10-23 Thread GitBox
C0urante commented on code in PR #12561: URL: https://github.com/apache/kafka/pull/12561#discussion_r1002789963 ## connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinatorIncrementalTest.java: ## @@ -517,13 +517,13 @@ public void testTaskAssig

[GitHub] [kafka] showuon commented on a diff in pull request #12752: KAFKA-14303 Fix batch.size=0 in BuiltInPartitioner

2022-10-23 Thread GitBox
showuon commented on code in PR #12752: URL: https://github.com/apache/kafka/pull/12752#discussion_r1002814235 ## core/src/test/scala/integration/kafka/api/PlaintextProducerSendTest.scala: ## @@ -55,6 +58,30 @@ class PlaintextProducerSendTest extends BaseProducerSendTest {

[GitHub] [kafka] showuon commented on a diff in pull request #12753: MINOR: Document Offset and Partition 0-indexing, fix typo

2022-10-23 Thread GitBox
showuon commented on code in PR #12753: URL: https://github.com/apache/kafka/pull/12753#discussion_r1002816719 ## clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java: ## @@ -1581,6 +1581,19 @@ public void commitAsync(final Map offsets, Of * is invoke

[jira] [Commented] (KAFKA-14328) KafkaAdminClient should be Changing the exception level When an exception occurs

2022-10-23 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622909#comment-17622909 ] Luke Chen commented on KAFKA-14328: --- I understand your problem now. But I'm not quite

[jira] [Commented] (KAFKA-14328) KafkaAdminClient should be Changing the exception level When an exception occurs

2022-10-23 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622918#comment-17622918 ] Deng Ziming commented on KAFKA-14328: - Currently we don't pass the cause field for T

[GitHub] [kafka] dengziming commented on pull request #7862: KAFKA-9246:Update Heartbeat timeout when ConsumerCoordinator commit offset

2022-10-23 Thread GitBox
dengziming commented on PR #7862: URL: https://github.com/apache/kafka/pull/7862#issuecomment-1288328234 Let's re-consider this after KIP-848. -- 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

[GitHub] [kafka] dengziming closed pull request #7862: KAFKA-9246:Update Heartbeat timeout when ConsumerCoordinator commit offset

2022-10-23 Thread GitBox
dengziming closed pull request #7862: KAFKA-9246:Update Heartbeat timeout when ConsumerCoordinator commit offset URL: https://github.com/apache/kafka/pull/7862 -- 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

[jira] [Updated] (KAFKA-14328) KafkaAdminClient should be Changing the exception level When an exception occurs

2022-10-23 Thread shizhenzhen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shizhenzhen updated KAFKA-14328: Attachment: image-2022-10-24-14-28-10-365.png > KafkaAdminClient should be Changing the exception

[jira] [Updated] (KAFKA-14328) KafkaAdminClient should be Changing the exception level When an exception occurs

2022-10-23 Thread shizhenzhen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shizhenzhen updated KAFKA-14328: Attachment: image-2022-10-24-14-47-30-641.png > KafkaAdminClient should be Changing the exception

[jira] [Updated] (KAFKA-14328) KafkaAdminClient should be Changing the exception level When an exception occurs

2022-10-23 Thread shizhenzhen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shizhenzhen updated KAFKA-14328: Attachment: image-2022-10-24-14-48-27-907.png > KafkaAdminClient should be Changing the exception

[jira] [Commented] (KAFKA-14328) KafkaAdminClient should be Changing the exception level When an exception occurs

2022-10-23 Thread shizhenzhen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622984#comment-17622984 ] shizhenzhen commented on KAFKA-14328: - [~dengziming] [~showuon]      超时的时候 可以把最后一次