草庐IT

KafkaSpout

全部标签

java - KafkaSpout 工作示例

关闭。这个问题需要debuggingdetails.它目前不接受答案。编辑问题以包含desiredbehavior,aspecificproblemorerror,andtheshortestcodenecessarytoreproducetheproblem.这将有助于其他人回答问题。关闭7年前。Improvethisquestion我最近熟悉了ApacheKafka,并且有一个生产者-消费者的工作示例。我的下一步是将Kafka与Spout和Bolt集成,我很难让可用的示例(它们大多是旧的)在本地工作。我得到了以下工作storm-b​​ook/examples-ch02-gettin