[jira] [Assigned] (KAFKA-13588) We should consolidate `changelogFor` methods to simplify the generation of internal topic names

[ https://issues.apache.org/jira/browse/KAFKA-13588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sayantanu Dey reassigned KAFKA-13588: - Assignee: Sayantanu Dey > We should consolidate `changelogFor` methods to simplify the

[GitHub] [kafka] C0urante commented on a change in pull request #10907: KAFKA-10000: Exactly-once support for source connectors (KIP-618)

C0urante commented on a change in pull request #10907: URL: https://github.com/apache/kafka/pull/10907#discussion_r785355853 ## File path: connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java ## @@ -337,15 +353,29 @@ private void readToLogEnd() {

[GitHub] [kafka] C0urante commented on a change in pull request #10907: KAFKA-10000: Exactly-once support for source connectors (KIP-618)

C0urante commented on a change in pull request #10907: URL: https://github.com/apache/kafka/pull/10907#discussion_r785355793 ## File path: connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java ## @@ -16,95 +16,46 @@ */ package

[GitHub] [kafka] florin-akermann commented on a change in pull request #11456: KAFKA-13351: Add possibility to write kafka headers in Kafka Console Producer

florin-akermann commented on a change in pull request #11456: URL: https://github.com/apache/kafka/pull/11456#discussion_r785328925 ## File path: core/src/main/scala/kafka/tools/ConsoleProducer.scala ## @@ -264,39 +278,92 @@ object ConsoleProducer { var reader:

[GitHub] [kafka] showuon commented on pull request #11681: KAFKA-8785: fix request timeout by waiting for brokers up at the begining

showuon commented on pull request #11681: URL: https://github.com/apache/kafka/pull/11681#issuecomment-1013677651 @hachikuji @dajac , please take a look. Thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [kafka] showuon commented on a change in pull request #11681: KAFKA-8785: fix request timeout by waiting for brokers up at the begining

showuon commented on a change in pull request #11681: URL: https://github.com/apache/kafka/pull/11681#discussion_r785305395 ## File path: core/src/test/java/kafka/testkit/KafkaClusterTestKit.java ## @@ -404,7 +404,10 @@ public Properties controllerClientProperties() throws

[GitHub] [kafka] showuon commented on a change in pull request #11681: KAFKA-8785: fix request timeout by waiting for brokers up at the begining

showuon commented on a change in pull request #11681: URL: https://github.com/apache/kafka/pull/11681#discussion_r785305376 ## File path: core/src/test/java/kafka/test/junit/RaftClusterInvocationContext.java ## @@ -179,7 +179,7 @@ public KafkaClusterTestKit getUnderlying() {