[
https://issues.apache.org/jira/browse/KAFKA-6646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18110128#comment-18110128
]
Hrishi Baskaran commented on KAFKA-6646:
----------------------------------------
hey [~mjsax] [~guozhang] is this something that we still want?
I could look into the internals of GlobalStreamThread to see what changes are
required to make this feasible and make a KIP?
> 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: api, 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
(v8.20.10#820010)
