[GitHub] [kafka] karuturi commented on pull request #11955: KAFKA-12380 Executor in Connect's Worker is not shut down when the worker is

2022-04-03 Thread GitBox
karuturi commented on PR #11955: URL: https://github.com/apache/kafka/pull/11955#issuecomment-1087171617 @showuon Sure, can wait. Hope we will merge one of them soon :) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [kafka] ijuma commented on pull request #11991: KAFKA-13794: Fix comparator of inflightBatchesBySequence in TransactionManager

2022-04-03 Thread GitBox
ijuma commented on pull request #11991: URL: https://github.com/apache/kafka/pull/11991#issuecomment-1086923746 Also cc @kirktrue -- 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 co

[jira] [Comment Edited] (KAFKA-13793) Add validators for serialization and deserialization related configuration

2022-04-03 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516472#comment-17516472 ] RivenSun edited comment on KAFKA-13793 at 4/3/22 1:07 PM: -- I co

[jira] [Comment Edited] (KAFKA-13793) Add validators for serialization and deserialization related configuration

2022-04-03 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516472#comment-17516472 ] RivenSun edited comment on KAFKA-13793 at 4/3/22 12:20 PM: --- I

[jira] [Comment Edited] (KAFKA-13793) Add validators for serialization and deserialization related configuration

2022-04-03 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516472#comment-17516472 ] RivenSun edited comment on KAFKA-13793 at 4/3/22 12:17 PM: --- I

[GitHub] [kafka] jeqo opened a new pull request #11993: KAFKA-13654: Extend KStream process with new Processor API

2022-04-03 Thread GitBox
jeqo opened a new pull request #11993: URL: https://github.com/apache/kafka/pull/11993 KIP-820 implementation. Changes: - Implement changes proposed in the KIP. - Adapt existing methods to implement FixedKeyProcessor instead of Processor, to guarantee fixed keys. *Su

[jira] [Comment Edited] (KAFKA-13793) Add validators for serialization and deserialization related configuration

2022-04-03 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516472#comment-17516472 ] RivenSun edited comment on KAFKA-13793 at 4/3/22 12:05 PM: --- I

[jira] [Comment Edited] (KAFKA-13793) Add validators for serialization and deserialization related configuration

2022-04-03 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516472#comment-17516472 ] RivenSun edited comment on KAFKA-13793 at 4/3/22 11:58 AM: --- I

[jira] [Comment Edited] (KAFKA-13793) Add validators for serialization and deserialization related configuration

2022-04-03 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516472#comment-17516472 ] RivenSun edited comment on KAFKA-13793 at 4/3/22 10:59 AM: --- I

[GitHub] [kafka] YeonCheolGit edited a comment on pull request #11990: KAFKA-13792: Fix wrong package name in Scala test files

2022-04-03 Thread GitBox
YeonCheolGit edited a comment on pull request #11990: URL: https://github.com/apache/kafka/pull/11990#issuecomment-1086803774 @dengziming Thank you for the review! Maybe this is silly question and just wondering that putting into different directories intentionally, what’s the advant

[GitHub] [kafka] YeonCheolGit edited a comment on pull request #11990: KAFKA-13792: Fix wrong package name in Scala test files

2022-04-03 Thread GitBox
YeonCheolGit edited a comment on pull request #11990: URL: https://github.com/apache/kafka/pull/11990#issuecomment-1086803774 -- 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.

[GitHub] [kafka] YeonCheolGit edited a comment on pull request #11990: KAFKA-13792: Fix wrong package name in Scala test files

2022-04-03 Thread GitBox
YeonCheolGit edited a comment on pull request #11990: URL: https://github.com/apache/kafka/pull/11990#issuecomment-1086803774 @dengziming Thank you for the review! Maybe this is silly question and just wondering that putting into different directories intentionally, what’s the point?

[GitHub] [kafka] YeonCheolGit edited a comment on pull request #11990: KAFKA-13792: Fix wrong package name in Scala test files

2022-04-03 Thread GitBox
YeonCheolGit edited a comment on pull request #11990: URL: https://github.com/apache/kafka/pull/11990#issuecomment-1086803774 @dengziming Thank you for the review! Maybe this is silly question. Just wondering that putting into different directories intentionally, what’s the point?

[GitHub] [kafka] YeonCheolGit edited a comment on pull request #11990: KAFKA-13792: Fix wrong package name in Scala test files

2022-04-03 Thread GitBox
YeonCheolGit edited a comment on pull request #11990: URL: https://github.com/apache/kafka/pull/11990#issuecomment-1086803774 @dengziming Thank you for the review! Just wondering that putting into different directories intentionally, what’s the point? -- This is an automated message f

[GitHub] [kafka] YeonCheolGit edited a comment on pull request #11990: KAFKA-13792: Fix wrong package name in Scala test files

2022-04-03 Thread GitBox
YeonCheolGit edited a comment on pull request #11990: URL: https://github.com/apache/kafka/pull/11990#issuecomment-1086803774 @dengziming Thank you for the review! Just wondering that put into different directories intentionally, what’s the point? -- This is an automated message from

[GitHub] [kafka] YeonCheolGit commented on pull request #11990: KAFKA-13792: Fix wrong package name in Scala test files

2022-04-03 Thread GitBox
YeonCheolGit commented on pull request #11990: URL: https://github.com/apache/kafka/pull/11990#issuecomment-1086803774 @dengziming Thank you for review! Just wondering that put into different directories intentionally, what’s the point? -- This is an automated message from the Apache

[jira] [Comment Edited] (KAFKA-13793) Add validators for serialization and deserialization related configuration

2022-04-03 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516472#comment-17516472 ] RivenSun edited comment on KAFKA-13793 at 4/3/22 8:31 AM: -- I co

[jira] [Commented] (KAFKA-13793) Add validators for serialization and deserialization related configuration

2022-04-03 Thread RivenSun (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516472#comment-17516472 ] RivenSun commented on KAFKA-13793: -- I combed through all the configs, and the following

[GitHub] [kafka] RivenSun2 commented on pull request #11992: MINOR: Fix wrong configuration of `inter.broker.security.protocol` for communication between brokers

2022-04-03 Thread GitBox
RivenSun2 commented on pull request #11992: URL: https://github.com/apache/kafka/pull/11992#issuecomment-1086799018 Hi @showuon @dajac please help to review the PR . Thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitH

[GitHub] [kafka] RivenSun2 opened a new pull request #11992: MINOR: Fix wrong configuration of `inter.broker.security.protocol` for communication between brokers

2022-04-03 Thread GitBox
RivenSun2 opened a new pull request #11992: URL: https://github.com/apache/kafka/pull/11992 Fix wrong configuration of inter.broker.security.protocol for communication between brokers -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Updated] (KAFKA-13794) Producer batch lost silently in TransactionManager

2022-04-03 Thread xuexiaoyue (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuexiaoyue updated KAFKA-13794: --- Summary: Producer batch lost silently in TransactionManager (was: Producer batch loss silently in T

[jira] [Updated] (KAFKA-13794) Producer batch loss silently in TransactionManager

2022-04-03 Thread xuexiaoyue (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuexiaoyue updated KAFKA-13794: --- Summary: Producer batch loss silently in TransactionManager (was: In flight batch being deleted sil

[jira] [Updated] (KAFKA-13794) In flight batch being deleted silently by another completed batch

2022-04-03 Thread xuexiaoyue (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuexiaoyue updated KAFKA-13794: --- Description: Under the case of idempotence is enabled, when a batch reaches its request.timeout.ms

[GitHub] [kafka] ddrid commented on pull request #11991: KAFKA-13794: Fix comparator of inflightBatchesBySequence in TransactionManager

2022-04-03 Thread GitBox
ddrid commented on pull request #11991: URL: https://github.com/apache/kafka/pull/11991#issuecomment-1086795717 Hi, @hachikuji, could you please help review this? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

[GitHub] [kafka] ddrid opened a new pull request #11991: KAFKA-13794: Fix comparator of inflightBatchesBySequence in TransactionManager

2022-04-03 Thread GitBox
ddrid opened a new pull request #11991: URL: https://github.com/apache/kafka/pull/11991 As described in https://issues.apache.org/jira/browse/KAFKA-13794, inflightBatchesBySequence in TransactionManager is not being remove correctly. One batch may be removed by another batch with the same

[jira] [Created] (KAFKA-13794) In flight batch being deleted silently by another completed batch

2022-04-03 Thread xuexiaoyue (Jira)
xuexiaoyue created KAFKA-13794: -- Summary: In flight batch being deleted silently by another completed batch Key: KAFKA-13794 URL: https://issues.apache.org/jira/browse/KAFKA-13794 Project: Kafka