kafka-jira mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Matthias J. Sax (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (KAFKA-6646) Add a GlobalKStream object type for stream event broadcast
Date Wed, 14 Mar 2018 05:38:00 GMT

     [ https://issues.apache.org/jira/browse/KAFKA-6646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel

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

View raw message