创建指向Kafka生产者/示例Java代码的Storm拓扑
真的很感谢你的帮助。
谢谢
共有1个答案
你的问题很笼统，因此很难回答。下面是一个Kafka喷口的示例https://github.com/apache/storm/blob/master/external/storm-kafka/src/jvm/org/apache/storm/Kafka/kafkaspout.java
您还需要实现自己的Bolt（使用IRichBolt或BaseBolt）。
在main方法中，可以使用TopolGoyBuilder将它们连接在一起。像这样：https://github.com/apache/storm/blob/master/examples/storm-starter/src/jvm/org/apache/storm/starter/wordcounttopology.java
WorkCount示例还包含在本地（LocalCluster）或在实际Storm集群（StormSubmitter）中远程执行代码的代码。
希望这有帮助。这些示例与Maven/Git无关。只需使用您首选的IDE来运行它。
您还应该查看Storm web站点:https://Storm.apache.org/documentation/home.html，并阅读“Rationale”、“Tutorial”、“Setting up development Environment”和“Creating a new Storm Project”页面。
-
我正在尝试使用Eclipse在Linux中运行Storm启动示例。我收到以下错误和函数从未被调用。 错误： 我的拓扑类： 我正在虚拟机环境中工作，所以不知道这是否是由于安装了Zookeeper。有什么想法吗？
-
我从源主题收到一条消息。然后我将消息分成3个部分，并将每个部分发送到3个不同的主题。现在有2条消息成功传递到第2个主题。但是在发送第3条消息时，我们会收到异常（例如ProducerFencedException|OutOfOrderSequenceException|AuthorizationException|RecordLengthException） 如何回滚/还原前2个主题中的其他2条消息
-
我们目前在HDF（Hortonworks Dataflow）3.3.1上，它捆绑了Kafka 2.0.0，并且正在尝试使用分布式模式下的Kafka Connect，以推出一个Google Cloud PubSub接收器连接器。我们正在计划将一些元数据发回到Kafka主题中，并且需要将一个Kafka生产者集成到Sink任务Java代码的flush（）函数中。 这是否会对Kafka Connect向K
-
主要内容：KafkaProducer API,生产者API,配置设置,SimpleProducer应用程序,简单的消费者实例,SimpleConsumer应用程序在这一节中将创建一个使用Java客户端发布和使用消息的应用程序。 Kafka生产者客户端由以下API组成。 KafkaProducer API 下面来了解Kafka生产者API。 KafkaProducer API的核心部分是类。 类提供了一个选项，用于将Kafka代理的构造函数与以下方法连接起来。 类提供方法来异步发送消息到主题。 的
-
这是我的密码。
-
问题内容： 我们是新来的风暴。我们不知道如何创建拓扑，请帮助我们应对风暴。我们尝试了“ Windows上的狂风暴雨”一文中给出的示例wordcount c = topology。但是我们无法理解如何给出输入，以及风暴用户界面中输入存在的位置以及输出存在的位置。 问题答案： 输入和输出在Storm UI中不存在。在Storm UI中，您看不到发出的元组，处理时间，集群配置和集群的运行状况。要查看输出