kafka中消費者消費消息之每個線程維護一個KafkaConsumer實例

kafka中消費者消費消息之每個線程維護一個KafkaConsumer實例 1、首先啓動自己的kafka集羣喲。 1 啓動zk: 2 bin/zkServer.sh start conf/zoo.cfg。 3 驗證zk是否啓動成功: 4 bin/zkServer.sh status conf/zoo.cfg。 5 啓動kafka: 6 bin/kafka-server-start.sh -daem
相關文章
相關標籤/搜索