[
https://issues.apache.org/jira/browse/KAFKA-7849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16888772#comment-16888772
]
Omar Al-Safi commented on KAFKA-7849:
-------------------------------------
Thank you [~mjsax]! I want to validate my findings with you, as I understood
from the code and {{DEBUG}} logs, {{GlobalStreamThread}} should be responsible
for subscribing to all the global topics as I can see
[here|https://github.com/apache/kafka/blob/2.3/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java#L698],
therefore {{StreamThread}} shouldn't subscribe to any of these topics as the
{{GlobalStreamThread}} is the sole responsible for this. Based on this
understanding, I was looking at {{sourceTopicPattern()}} in
{{InternalTopologyBuilder}} since is responsible for returning the topics
pattern that consumer in {{StreamThread}} should subscribe to, as I can see,
this method doesn't pay attention to the global topics although we have this
information in {{globalTopics}} HashSet, therefore I believe to fix this issue,
we will just need to filter out all global topics from that method before
returning the topic pattern, do you think that makes since?
> Warning when adding GlobalKTable
> --------------------------------
>
> Key: KAFKA-7849
> URL: https://issues.apache.org/jira/browse/KAFKA-7849
> Project: Kafka
> Issue Type: Bug
> Components: streams
> Affects Versions: 2.1.0
> Reporter: Dmitry Minkovsky
> Assignee: Omar Al-Safi
> Priority: Minor
> Labels: newbie
>
> Per
> https://lists.apache.org/thread.html/59c119be8a2723c501e0653fa3ed571e8c09be40d5b5170c151528b5@%3Cusers.kafka.apache.org%3E
>
> When I add a GlobalKTable for topic "message-write-service-user-ids-by-email"
> to my topology, I get this warning:
>
> [2019-01-19 12:18:14,008] WARN
> (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:421)
> [Consumer
> clientId=message-write-service-55f2ca4d-0efc-4344-90d3-955f9f5a65fd-StreamThread-2-consumer,
> groupId=message-write-service] The following subscribed topics are not
> assigned to any members: [message-write-service-user-ids-by-email]
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
