Hello,
I am thinking of using the Kafka Steams feature to "unify" our real-time
and scheduled workflow. An example is that in our workflow with stages A-->
B --> C, the A --> B segment can be achieved in real-time, but B-->C
segment is usually a done with a scheduled job, running maybe once per ho
re currently
> working on having the state stores accessible like you mention and should
> be able to share some design docs shortly.
>
> Thanks
> Eno
>
> > On 19 Jun 2016, at 19:49, Yi Chen wrote:
> >
> > Hello,
> >
> > I am thinking of using the Kaf
Hello,
I am developing a service so that all clustered nodes form a consumer
group. I also need to run some logic on only one of the node. Can I use a
special single-partition topic for leader election? That is, in my node I
can use ConsumerRebalanceListener to make sure that if the "leader"
Topic