hi, You can use this veersion: <dependency> <groupId>net.wurstmeister.storm</groupId> <artifactId>storm-kafka-0.8-plus</artifactId> <version>0.4.0</version> </dependency>
This version works well with kafka 0.8.1.1 and storm 0.9.1 but with some bugs. If you want, you can git clone the latest version from github: https://github.com/apache/incubator-storm But you need to change your storm version to latest. James 이승진 <[email protected]> 於 2014/6/23 (週一) 9:44 AM 寫道﹕ I'm trying to use storm-kafka 0.9.0-wip16a-scala292 below is my spout config List<HostPort> hosts = new ArrayList<HostPort>(); hosts.add(new HostPort("host1",2181)); hosts.add(new HostPort("host2",2181)); SpoutConfig config = new SpoutConfig(new KafkaConfig.StaticHosts(hosts,3), "logs", "/storm",// path where brokers and consumers exist eg. /storm/borkers/topics/... and /storm/consumers/... topologyName); normalLogSpoutConfig.forceStartOffsetTime(-1); KafkaSpout normalLogSpout = new KafkaSpout(normalLogSpoutConfig); I got this error and worker dies. INFO kafka.consumer.SimpleConsumer - Reconnect in get offetset request due to socket error: java.io.EOFException: Received -1 when reading from channel, socket has likely been closed. I'm using kafka_2.9.2-0.8.1, so is it a version problem? or am I using wrong path?
