[ 
https://issues.apache.org/jira/browse/KAFKA-15561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17804761#comment-17804761
 ] 

Lianet Magrans commented on KAFKA-15561:
----------------------------------------

Hey [~phuctran], thanks for your interest! From the consumer point of view, at 
this moment we have an initial simple approach, based on a static config: the 
consumer relies on the 
[group.protocol|https://github.com/apache/kafka/blob/bdad1631824035c8c31163ca6d054feff5421b29/clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java#L111]
 config defined in the KIP, to check if the protocol is enabled. It then 
instantiates the new #AsyncKafkaConsumer, which is the only one that supports 
the new protocol. The logic is in the 
[ConsumerDelegateCreator|[https://github.com/apache/kafka/blob/30d9678b3b7d069da13edf5eb99fb0edb99f0a87/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerDelegateCreator.java#L60].]

This initial approach will soon be extended as part of 
[KAFKA-15284|https://issues.apache.org/jira/browse/KAFKA-15284] to dynamically 
determine if the new protocol is supported by the broker and should be used. 

> Client support for new SubscriptionPattern based subscription
> -------------------------------------------------------------
>
>                 Key: KAFKA-15561
>                 URL: https://issues.apache.org/jira/browse/KAFKA-15561
>             Project: Kafka
>          Issue Type: New Feature
>          Components: clients, consumer
>            Reporter: Lianet Magrans
>            Assignee: Phuc Hong Tran
>            Priority: Major
>              Labels: consumer-threading-refactor, kip-848, 
> kip-848-client-support
>             Fix For: 3.8.0
>
>
> New consumer should support subscribe with the new SubscriptionPattern 
> introduced in the new consumer group protocol. When subscribing with this 
> regex, the client should provide the regex in the HB request on the 
> SubscribedTopicRegex field, delegating the resolution to the server.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to