Re: Stream Applications are initialized

2020-03-07 Thread Michelle Francois
group.id` -- this config will be > ignored anyway and the `application.id` is used as consumer `group.id`. > > I would try to inspect the log (if required at DEBUG level) to get > more intel what the application is doing. > > > - -Matthias > > > On 2/23/20 1:09 PM, Mi

Stream Applications are initialized

2020-02-23 Thread Michelle Francois
I tried to create a kafka streams application, but there was a bug in my code. I believe there was a deadlock for my application and whenever I tried to run an application instance with the same StreamsConfig.APPLICATION_ID_CONFIG id it could not start. I had to create another instance with differe

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