Kafka Java API操做topic

Kafka官方提供了两个脚原本管理topic,包括topic的增删改查。其中kafka-topics.sh负责topic的建立与删除;kafka-configs.sh脚本负责topic的修改和查询,但不少用户都更加倾向于使用程序API的方式对topic进行操做。   上一篇文章中提到了如何使用客户端协议(client protocol)来建立topic,本文则使用服务器端的Java API对top
相关文章
相关标签/搜索