[
https://issues.apache.org/jira/browse/KAFKA-13203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17400645#comment-17400645
]
Guozhang Wang commented on KAFKA-13203:
---------------------------------------
Which version of Kafka is this issue reported? I just checked the source code
on trunk and from what I read this cannot happen.
> GlobalTopic is added to main consumer subscription
> --------------------------------------------------
>
> Key: KAFKA-13203
> URL: https://issues.apache.org/jira/browse/KAFKA-13203
> Project: Kafka
> Issue Type: Bug
> Components: streams
> Reporter: Matthias J. Sax
> Priority: Major
>
> From [https://github.com/confluentinc/kafka-streams-examples/issues/351]
> {quote}I have the following topology.
> {{Topology topology = new Topology();}}
> {{//WS connection processor}}
> {{topology}}
> {{ .addSource(SOURCE1, new StringDeserializer(), new
> WebSocketConnectionEventDeserializer(), "topic1")}}
> {{ .addProcessor(PROCESSOR1, Processor1::new, SOURCE1)}}
> {{ .addStateStore(sessionStoreBuilder, PROCESSOR1)}}
> {{ .addSink(WS_STATUS_SINK, "sinktopic", stringSerializer, stringSerializer,
> PROCESSOR1)}}
> {{}}
> {{//Service discovery}}
> {{ .addGlobalStore(nodeTopicDiscoveryStoreBuilder, SOURCE3, new
> StringDeserializer(),
> new ServiceDiscoveryEventDeserializer(), "compacttopic",
> GLOBALSTOREPROCESSOR,
> GlobalStateStoreBuilder::new)}}
> {{}}
> {{//WS session routing}}
> {{ .addSource(SOURCE2, new StringDeserializer(), new StringDeserializer(),
> "topic2")}}
> {{ .addProcessor(PROCESSOR2, Processor2::new,
> SOURCE2)}}
> {{ .addStateStore(userConnectedNodesStoreBuilder, PROCESSOR2, PROCESSOR1);}}
> {{}}
> {{streams = new KafkaStreams(topology, kafkaStreamProperties); }}
> While running the application, I get the following error
> {{Consumer
> clientId=ws-stream-processor-6115be26-b6e0-49d7-9c47-d9215bfcfea8-StreamThread-1-consumer,
> groupId=ws-stream-processor] The following subscribed topics are not
> assigned to any members: [compacttopic]}}
> {quote}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
