Hi all, We recently upgrade our cluster from Strom 0.11 to 1.0.1.2.5.0.0-1245 (HortonWorks), Kafka from 0.8.2 to 0.10.0.1. We had integration tests using Storm LocalCluster, KafkaEmbedded and EmbeddedZookeeper that started failing sometimes (under load) after the upgrade. Just wanted to see if anybody had similar experience.
Another question, we were thinking of upgrading KafkaSpouts to new Consumer API but looks like Kafka Client in Maven central is not compatible with Kafka 0.10.0.1. If we build Kafka Client jar from Git, is it production ready? Thanks Kamal
