Antony Stubbs created KAFKA-6646:

             Summary: Add a GlobalKStream object type for stream event broadcast
                 Key: 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

Reply via email to