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)