Binh Van Nguyen

Does not work with busy topology

1

Hi, This application works fine with not busy topology but it does not work when topology is busy and Storm write to ZK faster than this application can read. I...

Fix out of range exception issue of partitioned Kafka spout

3

I modified KafkaUtils::emitPartitionBatchNew method to fix the out of range exception when fetch messages from Kafka's topic. This issue happens when there is no previous status in Zookeeper and the...