KafkaProducerTopology对象的Apache Storm Maven依赖项

Question

我使用的导入org.apache.storm.kafka.bolt.KafkaProducerTopology的Maven依赖是什么：

<dependency>
        <groupId>org.apache.storm</groupId>
        <artifactId>storm-kafka</artifactId>
        <version>1.0.1</version>
        <scope>provided</scope>
</dependency>`

但它不起作用。我需要一个有效版本的Kafka-Server xml，但我没有找到任何地方。

Answer 1

这是示例中的一个类，不是任何Maven依赖项的一部分

https://github.com/apache/storm/blob/master/examples/storm-kafka-client-examples/src/main/java/org/apache/storm/kafka/bolt/KafkaProducerTopology.java