Matthias J. Sax updated KAFKA-6646:
    Labels: needs-kip  (was: )

> 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
>            Priority: Major
>              Labels: needs-kip
> 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