Hi, Matthias, I think Vivek's question is not whether Kafka Streams can be used with a Kafka 0.9 broker (which it cannot). The question is whether Kafka Streams can process messages produced with a 0.9.0.1 producer into a 0.10.0.0 broker. Is that right? If so, would a custom TimestampExtractor work?
Ismael On Thu, Jul 7, 2016 at 12:29 PM, Matthias J. Sax <matth...@confluent.io> wrote: > Hi Vivek, > > Kafka Streams works only with Kafka 0.10 (but not with 0.9). > > I am not aware of any work around to allow for 0.9 usage. > > > -Matthias > > On 07/07/2016 05:37 AM, vivek thakre wrote: > > Can kafka streams library work with the messages produced by 0.9.0.1 > > producer? > > I guess not since the old producer would not add timestamp. ( I am > getting > > invalid timestamp exception) > > > > As I cannot change our producer application setup, I have to use 0.9.0.1 > > producer. > > Is there a workaround that I can try to use Kafka Streams? > > > > Thanks, > > Vivek > > > >