Forwarding consumer with kafka streams

2017-08-12 Thread Ricardo Costa
Hi, I've implemented a forwarding consumer which literally just consumes the messages from a source topic, logs them and then publishes them to a target topic. I wanted to keep the implementation simple with very little code so I went with kafka-streams. I have a really simple topology with a sou

Re: Forwarding consumer with kafka streams

2017-08-14 Thread Ricardo Costa
wrote: > > > Hi Ricardo, > > > > Kafka Streams should handle that case as well. What streams config are > you > > using, could you share it? There is one parameter that is called > > “ConsumerConfig.AUTO_OFFSET_RESET_CONFIG” and by default it’s set to > > “