文件名称:kafka-service-interface:公开Kafka生产者和消费者API的Docker服务
文件大小:42KB
文件格式:ZIP
更新时间:2024-06-15 09:20:57
Java
kafka服务接口 公开Kafka生产者和消费者API的Docker服务 该服务提供了一种简单的方法,可以将Kafka生产者和使用者API添加到您的应用程序中。 该Kafka服务与其他docker compose服务之间的通信是通过http回调完成的。 官方支持的Kafka客户端库使用Java。 已经编写了其他语言的客户端库,但是其中一些错误和过时。 这种方法使您可以轻松地将Kafka集成到任何其他语言中,同时获得正式支持的客户端库的好处。 实施细节: 公开Kafka发布回调网址 公开一个或多个Kafka消费者回调网址 包括失败的消息重试 包含无效的主题和回调网址 Docker撰写 回调格式 卡夫卡出版 { topic: 'topic.name', key: 'unique to spread evenly between partitions', mess
【文件预览】:
kafka-service-interface-master
----supervisord.conf(299B)
----pom.xml(4KB)
----RELEASE_NOTES.md(32B)
----Dockerfile(538B)
----src()
--------test()
--------main()
----samples()
--------nodejs()
----.gitignore(320B)
----diagram.png(21KB)
----README.md(4KB)