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)
