优艾设计网

Kafka message stream 怎么使用??

优艾设计网 https://www.uibq.com 2023-06-15 07:57 出处:网络 作者:PS百科
stream 的用法不是很清楚。比如下面这一段代码: Map<String, Integer> topicCount = new HashMap<String, Integer>(); topi优艾设计网_平面设计cCount.put(topic, 1); Map<String, List<KafkaStr

stream 的用法不是很清楚。
比如下面这一段代码:

Map<String, Integer> topicCount = new HashMap<String, Integer>(); topi优艾设计网_平面设计cCount.put(topic, 1); Map<String, List<KafkaStream<byte[], byte[]>>> streams = consumerConnector.createMessageStreams(topicCount);

这样是对这个topic获取一个stream对象,通过迭代器获取消息。
但是如果要是吧#Stream改成大于1的数字,比如3。

这样又是什么意思啊,是在partition为3的时候这样设置吗?
取出来3个stream又该怎么使用?


0

精彩评论

暂无评论...
验证码 换一张
取 消