0

我使用 apachestorm 作为分发系统来消耗和产生高负载的 Kafka 消息。到目前为止,我只发送了彻底 apache Storm 的消息,但现在我正试图通过 Storm 添加 Kafka 标头和消息正文。我想知道apache风暴是否支持这个?

<dependency>
  <groupId>org.apache.kafka</groupId>
  <artifactId>kafka-clients</artifactId>
  <version>1.0.0</version>
</dependency>
<dependency>
  <groupId>org.apache.storm</groupId>
  <artifactId>storm-kafka</artifactId>
  <version>1.2.2</version>
</dependency>
<dependency>

4

0 回答 0