kafka9使用demo

kafka9使用demojava 新的Comsumer API再也不有high-level、low-level之分了,而是本身维护offset。这样作的好处是避免应用出现异常时,数据未消费成功,但Position已经提交,致使消息未消费的状况发生。经过查看API,新的Comsumer API有如下功能:算法 Kafka能够自行维护Offset、消费者的Position。也能够开发者本身来维护Off
相关文章
相关标签/搜索