Hi Kang, I didn't see that issue and don't know about first question.
I'll answer the second question. storm-kafka-client 1.1.0 SNAPSHOT is compatible with Kafka 0.10, whereas storm-kafka-client 1.0.x is compatible with Kafka 0.9. Btw, HDP 1.0.1.2.5.0.0-1245 is based on snapshot of Storm 1.1.0 SNAPSHOT so you can pull it with adding Hortonworks remote repository to Maven. Hope this helps. Thanks, Jungtaek Lim (HeartSaVioR) 2016년 12월 7일 (수) 오전 1:32, Kang, Kamaljeet <kk...@verisign.com>님이 작성: > 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 > > >
