dropwizard-kafka-sse-consumer:通过 SSE 实时显示 kafka 传入消息

【文件属性】：

文件名称：dropwizard-kafka-sse-consumer:通过 SSE 实时显示 kafka 传入消息

文件大小：13KB

文件格式：ZIP

更新时间：2024-07-02 16:16:35

Java

通过服务器发送事件实时发布Kafka主题 此示例将向您展示如何轻松扩展 dropwizard-kafka-consumer 以构建一个微服务，该微服务可以通过 SSE 实时显示 kafka 主题的传入消息。 扩展 dropwizard-kafka-consumer 为了扩展 dropwizard-kafka-consumer 并构建这个新的微服务，我们只需要创建两个类。 消息发送者 MessageSender 类实现了接口 MessageHandler。 它包含一个 EventSource 实例列表。 每次，当新数据产生到 kafka 主题时，数据将由内置使用者委托给 MessageSender，后者将循环所有 EvenSource 实例并将数据作为新事件发送给每个实例。 卡夫卡SSE应用程序 这是主类，它将： 创建一个 MessageSender 实例作为内置 Kafka 消费者调用

【文件预览】：
dropwizard-kafka-sse-consumer-master
----src()
--------main()
----pom.xml(8KB)
----README.md(3KB)
----config.yml(207B)
----config-test.yml(205B)