将avro数据从java流发布到kafka

6kkfgxo0  于 2021-06-07  发布在  Kafka
关注(0)|答案(0)|浏览(193)

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);
}

这和预期的一样。但不是出版 avroeventstdout ,我想把它发表到一个Kafka的主题,叫做 events . 我已经安装并启动了Kafka,创建了这个主题 events 并且知道如何从控制台和文件发布到它。但是我不确定如何从我的java程序发布。我找到的每一个教程似乎都有点不同。。。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题