[GitHub] [kafka] GOODBOY008 commented on pull request #11644: KAFKA-13433:JsonConverter's method convertToJson when field is optional with default value and value is null, return default value.

2022-10-21 Thread GitBox
GOODBOY008 commented on PR #11644: URL: https://github.com/apache/kafka/pull/11644#issuecomment-1287632326 @kkonstantine Please review , If you are available ,Thank you! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [kafka] GOODBOY008 opened a new pull request, #11644: KAFKA-13433:JsonConverter's method convertToJson when field is optional with default value and value is null, return default value.

2022-10-21 Thread GitBox
GOODBOY008 opened a new pull request, #11644: URL: https://github.com/apache/kafka/pull/11644 Issue is [here](https://issues.apache.org/jira/browse/KAFKA-13433) . Problem: JsonConverter's method convertToJson when field is optional with default value and value is null, return defau

[GitHub] [kafka] GOODBOY008 closed pull request #11644: KAFKA-13433:JsonConverter's method convertToJson when field is optional with default value and value is null, return default value.

2022-10-21 Thread GitBox
GOODBOY008 closed pull request #11644: KAFKA-13433:JsonConverter's method convertToJson when field is optional with default value and value is null, return default value. URL: https://github.com/apache/kafka/pull/11644 -- This is an automated message from the Apache Git Service. To respond t

[GitHub] [kafka] littlehorse-eng commented on a diff in pull request #12393: WIP: KAFKA-12549 Prototype for transactional state stores

2022-10-21 Thread GitBox
littlehorse-eng commented on code in PR #12393: URL: https://github.com/apache/kafka/pull/12393#discussion_r1002288689 ## streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractTransactionalStore.java: ## @@ -0,0 +1,442 @@ +/* + * Licensed to the Apache Software

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

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

[jira] [Updated] (KAFKA-14302) Infinite probing rebalance if a changelog topic got emptied

2022-10-21 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-14302: --- Fix Version/s: 3.4.0 > Infinite probing rebalance if a changelog topic got e

[jira] [Commented] (KAFKA-14302) Infinite probing rebalance if a changelog topic got emptied

2022-10-21 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622499#comment-17622499 ] A. Sophie Blee-Goldman commented on KAFKA-14302: Oof. That's a silly one

[jira] [Commented] (KAFKA-14294) Kafka Streams should commit transaction when no records are processed

2022-10-21 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622498#comment-17622498 ] A. Sophie Blee-Goldman commented on KAFKA-14294: Mm, yeah this sounds si

[GitHub] [kafka] C0urante merged pull request #12764: MINOR: Remove duplicate test dependency declarations for clients module

2022-10-21 Thread GitBox
C0urante merged PR #12764: URL: https://github.com/apache/kafka/pull/12764 -- 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-unsubscr...@kafka.apache

[jira] [Commented] (KAFKA-14322) Kafka node eating Disk continuously

2022-10-21 Thread Abhijit Patil (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622354#comment-17622354 ] Abhijit Patil commented on KAFKA-14322: --- Can this be assigned to some one or looke

[GitHub] [kafka] OmniaGM commented on pull request #12577: KAFKA-13401: KIP-787 - MM2 manage Kafka resources with custom Admin implementation.

2022-10-21 Thread GitBox
OmniaGM commented on PR #12577: URL: https://github.com/apache/kafka/pull/12577#issuecomment-1287144965 > > The `MirrorMakerConfigTest` tests the config part, but there's nothing that proves that the configured ForwardingAdmin is actually used when creating topics, ACLs etc. That might not

[GitHub] [kafka] cadonna commented on a diff in pull request #12771: KAFKA-14299: Handle TaskCorruptedException during initialization

2022-10-21 Thread GitBox
cadonna commented on code in PR #12771: URL: https://github.com/apache/kafka/pull/12771#discussion_r1001636845 ## streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java: ## @@ -1435,6 +1435,31 @@ public void shouldRethrowTaskCorruptedExceptionFr

[jira] [Commented] (KAFKA-14282) RecordCollector throws exception on message processing

2022-10-21 Thread Daniel Heinrich (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622182#comment-17622182 ] Daniel Heinrich commented on KAFKA-14282: - We are seeing the same problem. We ar

[GitHub] [kafka] cadonna commented on pull request #12505: KAFKA-14133: Replace EasyMock with Mockito in streams tests

2022-10-21 Thread GitBox
cadonna commented on PR #12505: URL: https://github.com/apache/kafka/pull/12505#issuecomment-1286760706 @clolov What is the status of this PR? -- 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] [Commented] (KAFKA-14328) KafkaAdminClient should be Changing the exception level When an exception occurs

2022-10-21 Thread shizhenzhen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622140#comment-17622140 ] shizhenzhen commented on KAFKA-14328: - 如果是发生请求的时候 导致的超时,代码里面或许是会把超时时候的异常给打印出来。   但

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

2022-10-21 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-21-16-58-19-353.png > KafkaAdminClient should be Changing the exception

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

2022-10-21 Thread shizhenzhen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622136#comment-17622136 ] shizhenzhen edited comment on KAFKA-14328 at 10/21/22 8:56 AM:

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

2022-10-21 Thread shizhenzhen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622136#comment-17622136 ] shizhenzhen commented on KAFKA-14328: - [~showuon]   感谢回复, 像你说的一样,我们期望通过重试能够解决这个异常,但是

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

2022-10-21 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-21-16-54-40-588.png > KafkaAdminClient should be Changing the exception

[jira] [Commented] (KAFKA-14045) Heartbeat threads cause high CPU usage after broker shut down

2022-10-21 Thread MillieZhang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622092#comment-17622092 ] MillieZhang commented on KAFKA-14045: - This is a duplicate issue with [KAFKA-13917|

[jira] [Commented] (KAFKA-13917) Avoid calling lookupCoordinator() in tight loop

2022-10-21 Thread MillieZhang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622091#comment-17622091 ] MillieZhang commented on KAFKA-13917: - hello,this issue also affects 2.8.X !image-2

[jira] [Updated] (KAFKA-13917) Avoid calling lookupCoordinator() in tight loop

2022-10-21 Thread MillieZhang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] MillieZhang updated KAFKA-13917: Attachment: image-2022-10-21-15-53-14-689.png > Avoid calling lookupCoordinator() in tight loop >

[jira] [Updated] (KAFKA-13917) Avoid calling lookupCoordinator() in tight loop

2022-10-21 Thread MillieZhang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] MillieZhang updated KAFKA-13917: Attachment: image-2022-10-21-15-52-20-402.png > Avoid calling lookupCoordinator() in tight loop >

[jira] [Commented] (KAFKA-12241) Partition offline when ISR shrinks to leader and LogDir goes offline

2022-10-21 Thread Tobias Gustafsson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17621891#comment-17621891 ] Tobias Gustafsson commented on KAFKA-12241: --- We've also been hit by this issue