(kafka) branch trunk updated: KAFKA-17544: Add log message for early access use of KafkaShareConsumer (#17940)

[manikumar]

This is an automated email from the ASF dual-hosted git repository.

manikumar 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 5480d54d185 KAFKA-17544: Add log message for early access use of 
KafkaShareConsumer (#17940)
5480d54d185 is described below

commit 5480d54d185e236bffe003c88afa84b924d816b8
Author: Andrew Schofield <aschofi...@confluent.io>
AuthorDate: Tue Nov 26 04:45:43 2024 +0000

    KAFKA-17544: Add log message for early access use of KafkaShareConsumer 
(#17940)
    
    When a KafkaShareConsumer is constructed in AK 4.0, a log message is 
written warning about the early access nature of the feature.
    
    Reviewers: Manikumar Reddy <manikumar.re...@gmail.com>
---
 .../clients/consumer/internals/ShareConsumerDelegateCreator.java   | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git 
a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumerDelegateCreator.java
 
b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumerDelegateCreator.java
index aeaaec7add7..625f6abf0cd 100644
--- 
a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumerDelegateCreator.java
+++ 
b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumerDelegateCreator.java
@@ -25,6 +25,8 @@ import org.apache.kafka.common.serialization.Deserializer;
 import org.apache.kafka.common.utils.LogContext;
 import org.apache.kafka.common.utils.Time;
 
+import org.slf4j.Logger;
+
 /**
  * {@code ShareConsumerDelegateCreator} implements a quasi-factory pattern to 
allow the caller to remain unaware of the
  * underlying {@link ShareConsumer} implementation that is created. This 
provides the means by which
@@ -41,6 +43,9 @@ public class ShareConsumerDelegateCreator {
                                                      final Deserializer<K> 
keyDeserializer,
                                                      final Deserializer<V> 
valueDeserializer) {
         try {
+            LogContext logContext = new LogContext();
+            Logger log = logContext.logger(getClass());
+            log.warn("Share groups and KafkaShareConsumer are part of the 
early access of KIP-932 and MUST NOT be used in production.");
             return new ShareConsumerImpl<>(config, keyDeserializer, 
valueDeserializer);
         } catch (KafkaException e) {
             throw e;
@@ -60,6 +65,8 @@ public class ShareConsumerDelegateCreator {
                                                      final SubscriptionState 
subscriptions,
                                                      final ConsumerMetadata 
metadata) {
         try {
+            Logger log = logContext.logger(getClass());
+            log.warn("Share groups and KafkaShareConsumer are part of the 
early access of KIP-932 and MUST NOT be used in production.");
             return new ShareConsumerImpl<>(
                     logContext,
                     clientId,