文件名称：dropwizard-kafka-consumer:使用 Dropwizard 构建的普通 kafka 消费者
文件大小：19KB
文件格式：ZIP
更新时间：2024-07-11 08:03:44
Java
普通 Kafka 消费者作为微服务 越来越多的人在谈论微服务架构，并且在许多项目中 kafka 已被用作哑管道。 本项目试图构建一个标准的kafka消费者，可以作为进一步扩展的基础。 该项目中使用 Dropwizard 框架使其作为微服务运行。 核心组件 该项目基于 SRP 设计原则构建了两个关键组件。 KafkaMessageConsumer - 处理 kafka 主题消费 KafkaMessageConsumer 有两个方法 start() 和 stop()。 调用 start() 方法后，KafkaMessageConsumer 将准备好使用给定主题的任何传入消息。 调用 stop() 方法将释放资源。 KafkaMessageConsumer 的生命周期将由类 KafkaMessageConsumerManager 控制，该类实现了 io.dropwizard.lifecycle.
【文件预览】：
dropwizard-kafka-consumer-master
----pom.xml(10KB)
----config-test.yml(201B)
----src()
--------test()
--------main()
----config.yml(203B)
----README.md(3KB)