Spring xd stream - kafka

2015-10-16 Thread bigdata hadoop
Hi Kafka Users I am new to streams in spring xd and trying to consumer data from a topic. I downloaded the spring xd single node on my laptop and ran the following command: 1. stream create myKafka --definition "kafka --zkconnect=localhost:2181 --topic=mytopic | log" --deploy I did not see the lo

Offsets not matching with the count

2015-12-08 Thread bigdata hadoop
Hi All I have a topic with encrypted data. I am using spring-xd streams kafka source and my processor which decrypts the message and writes to file. So the issue I am facing is the offsets or throughput isn't matching with the topic offsets. I also made a tap on the stream for counting the message