Re: Kafka Streams for Remote Server

2016-07-28 Thread mishadoff
nvironment only. > > Guozhang > > > On Wed, Jul 27, 2016 at 5:45 AM, mishadoff wrote: > >> Hello, >> >> I’ve a simplest ever kafka streams application which just reads from one >> kafka topic A and write to another topic B. >> >>

Kafka Streams for Remote Server

2016-07-27 Thread mishadoff
Hello, I’ve a simplest ever kafka streams application which just reads from one kafka topic A and write to another topic B. When I run it on my local environment (local zk, local kafka broker, local kafka streams app) everything works fine, topic B created and filled with messages from A If I

Re: [Kafka Streams] Source Nodes

2016-06-29 Thread mishadoff
er.stream(...).map(...).through(...); >>>> > > Btw: this problem got fixed already; if you use current trunk version > you do not need the additional call to through(...) > > -Matthias > > > On 06/29/2016 06:02 PM, mishadoff wrote: >> Hey, >>

[Kafka Streams] Source Nodes

2016-06-29 Thread mishadoff
Hey, I am trying to understand kafka-streams and doing a simple prototype for joining KStream with KTable, but stuck at the error: Invalid topology building: KSTREAM-MAP-01 and KSTREAM-AGGREGATE-04 are not joinable I tracked down the issue is thrown where stream or table have s