storm-contrib

storm-contrib copied to clipboard

storm-kafka and kafka_2.9.2 "0.8.x", "0.9.x" compatibility

7

hello seeking to run storm-kafka against newer kafka codebase (0.8.x, 0.9.x) codebease in contrib/storm-kafka is compatible with 0.7.x only.. any chance in the near term for a port to the...

andrewmilkowski

License?

1

Under which license is this repository? MIT? Apache-2.0? Or something else?

reiz

I run the storm cluster, encountered the following problems, I hope a great God can put forward solution. error info: Client client-boss-1 [ERROR] connection attempt 2 to Netty-Client-storm3/192.168.172.133:6700 failed: java.net.ConnectException:...

caiminDreamFly

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...

binhnv

StreamID for kafka-spout emits?

1

If I've a number of spout implementations in a plant, and they are all using the KafkaSpout implementation... is there any means or desire for a means (other than mine...

ghost

TransactionalTridentKafkaSpout works correctly in local cluster, but fails to get any message in remote cluster

4

I am using TransactionalTridentKafkaSpout and transactional trident state, it works correctly in local cluster, but fails to get any message when I deploy it to a remote cluster In both...

philipgao

[storm-rdbms] java.lang.NullPointerException when using storm on cluster mode

3

It can run correctly in the local mode when I write to my mysql database. But when I use in storm cluster mode, it fails. I submit my topology by...

jamesweb1

...k version conflics. curator-framework-1.0.1 and curator-framework-1.3.3 have different method definition, includeing: 1) netflix.curator.framework.api.CreateBuilder.creatingParentsIfNeeded() has different return types; 2) CuratorFrameworkFactory.newClient(...) doesn't throw IOException anymore in v1.3.3; When using [storm/storm-kafka "0.9.0-wip16a-scala292"] on...

Gvain

As per Issue #31, update list of aggregated modules in root pom.xml file, bringing it in line with all the child poms that are found. Projects without a pom.xml: storm-{backports,benchmark,examples,kafka,redis-pubsub,state}

rektide

Migrate storm-kafka to maven to match other storm-contrib projects

1

Migrate storm-kafka to maven from len to match with the other storm-contrib projects. Added ignores to support maven/eclipse.

nerdynick