You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2021/08/15 18:40:00 UTC
[jira] [Created] (KAFKA-13203) GlobalTopic is added to main
consumer subscription
Matthias J. Sax created KAFKA-13203:
---------------------------------------
Summary: 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
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)