Antony Stubbs created KAFKA-6646:
------------------------------------
Summary: Add a GlobalKStream object type for stream event broadcast
Key: KAFKA-6646
URL: https://issues.apache.org/jira/browse/KAFKA-6646
Project: Kafka
Issue Type: New Feature
Components: streams
Affects Versions: 1.1.0
Reporter: Antony Stubbs
There are some use cases where having a global KStream object is useful. For
example, where a single event is sent, with very low frequency, to a cluster of
Kafka stream nodes to trigger all nodes to do some processing of state stored
on their instance.
Workaround currently is to either create a second kstream app instance, being
careful to configure it with a different state dir, and give it a unique app
name per instance, then create a kstream in each one. Or - you can use the
normal consumer client inside your kstream app with unique consumer groups.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
