java和Kafka对我来说都是新事物,所以如果这不是一个好问题,请原谅我。
我已经编写了一个java应用程序来监听在线提要。每当出现新事件时,方法 onEvent
将信息转换为avro对象并将其写入 stdout
:
public void onEvent(Event event) {
Avroevent avroevent = new Avroevent();
avroevent.setInfo1(event.getInfo1());
avroevent.setInfo2(event.getInfo2());
String smgs = avroevent.toString();
System.out.println(smgs);
}
这和预期的一样。但不是出版 avroevent
至 stdout
,我想把它发表到一个Kafka的主题,叫做 events
. 我已经安装并启动了Kafka,创建了这个主题 events
并且知道如何从控制台和文件发布到它。但是我不确定如何从我的java程序发布。我找到的每一个教程似乎都有点不同。。。
暂无答案!
目前还没有任何答案,快来回答吧!