[kafka] branch trunk updated: KAFKA-7824; Require member.id for initial join group request [KIP-394] (#6058)

This is an automated email from the ASF dual-hosted git repository. jgus pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new 9a9310d KAFKA-7824; Require member.id for initial jo

[kafka] Diff for: [GitHub] hachikuji merged pull request #6058: KAFKA-7824: Require member.id for initial join group request

diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java index fb710f1518f..c33d017b4b5 100644 --- a/clients/src/main/java/org/apache/kafka/clients/consume

[kafka] branch trunk updated: KAFKA-7792: Add simple /agent/uptime and /coordinator/uptime health check endpoints (#6130)

This is an automated email from the ASF dual-hosted git repository. cmccabe pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new 2e53fa0 KAFKA-7792: Add simple /agent/uptime and

[kafka] Diff for: [GitHub] cmccabe merged pull request #6130: KAFKA-7792: Add simple /agent/uptime and /coordinator/uptime health check endpoints

diff --git a/tools/src/main/java/org/apache/kafka/trogdor/agent/Agent.java b/tools/src/main/java/org/apache/kafka/trogdor/agent/Agent.java index c76ef263c22..699e14b4ca8 100644 --- a/tools/src/main/java/org/apache/kafka/trogdor/agent/Agent.java +++ b/tools/src/main/java/org/apache/kafka/trogdor/ag

[kafka] branch trunk updated: MINOR: Streams upgrade guide section for newly merged KIPs (#6108)

This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new 68a6a7a MINOR: Streams upgrade guide section for

[kafka] Diff for: [GitHub] guozhangwang merged pull request #6108: MINOR: Streams upgrade guide section for newly merged KIPs

diff --git a/docs/streams/upgrade-guide.html b/docs/streams/upgrade-guide.html index 7fecfeb4973..d2e4a2e0a43 100644 --- a/docs/streams/upgrade-guide.html +++ b/docs/streams/upgrade-guide.html @@ -68,6 +68,23 @@ Upgrade Guide and API Changes More details about the new config StreamsConfig

[kafka] Diff for: [GitHub] guozhangwang merged pull request #6144: MINOR: Add log entry for KafkaException

diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java index a8db7e8a137..851187319e6 100644 --- a/streams/src/main/java/org/apache/kafka/streams/processor/internals

[kafka] branch trunk updated: MINOR: Add log entry for KafkaException in StreamThread#runLoop (#6144)

This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new 3dffd5d MINOR: Add log entry for KafkaException

[kafka] branch trunk updated: KAFKA-7391; Introduce close(Duration) to Producer and AdminClient instead of close(long, TimeUnit) (#5667)

This is an automated email from the ASF dual-hosted git repository. jgus pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new af634a4 KAFKA-7391; Introduce close(Duration) to Pro

[kafka] Diff for: [GitHub] hachikuji merged pull request #5667: KAFKA-7391 Introduce close(Duration) to Producer and AdminClient inst…

diff --git a/clients/src/main/java/org/apache/kafka/clients/admin/AdminClient.java b/clients/src/main/java/org/apache/kafka/clients/admin/AdminClient.java index fdda622e030..1521ee53e1f 100644 --- a/clients/src/main/java/org/apache/kafka/clients/admin/AdminClient.java +++ b/clients/src/main/java/