Re: StateStore extends UnicastRemoteObject

2020-01-06 Thread Bruno Cadonna
Hi Michelle, Are you sure you do not pass a null instead of your custom store to your topology by mistake? How does the implementation of the `build()` method of your `MyCustomStoreBuilder` look like? Best, Bruno On Mon, Dec 30, 2019 at 12:06 AM Michelle Francois wrote: > > Hello, > I want to h

StateStore extends UnicastRemoteObject

2019-12-29 Thread Michelle Francois
Hello, I want to have two way communication in Apache Kafka and since the Apache Kafka Topology permits no cyclic topology I was suggested by my supervisor to use State Stores as remote objects. I created custom State Stores as described here: https://docs.confluent.io/current/streams/developer-gu