小编Cag*_*tay的帖子

如何从特定主题中删除 Kafka 消费者组?

我更改了侦听 Kafka 主题的 Web 服务的消费者组 ID。现在,旧的组ID仍然注册到主题,但是没有具有该组ID的消费者。因此,它是滞后的。如何从特定主题中删除特定消费者组?

我试过这个:

kafka-consumer-groups --bootstrap-server kafka01.myserver.com:9092 --topic notification-topic --delete --group old-consumer-group --execute

但它返回:“消费者不支持从消费者组删除特定于主题的偏移量。

我应该完全删除消费者组吗?我使用相同的组ID收听其他主题,它们会受到影响吗?

consumer apache-kafka kafka-consumer-api

14
推荐指数
1
解决办法
2万
查看次数

使用 Stream.sum() 多次消费流

流只能被操作(调用中间或终端流操作)一次。

我明白了这个想法,但是为什么找到流的总和不会消耗它呢?我可以运行下面的代码,没有任何异常。

double totalPrice = stream.mapToDouble(product -> product.price).sum();
List<Product> products = stream.map(this::convert).collect(Collectors.toList());
Run Code Online (Sandbox Code Playgroud)

为什么sum不是终端运营商?它与将流元素收集到列表中有何不同?

java java-stream

5
推荐指数
1
解决办法
2713
查看次数