kafka为什么会丢消息 JAVA面试如何保证消息不被重复消费？如何保证消息消费的幂等性？

JAVA面试如何保证消息不被重复消费？如何保证消息消费的幂等性？

我没事，来这里玩，开始在各种网络上寻找技术信息，之后以“头条”为主。从寻找信息到交朋友。因为我觉得事情落后于时代，有人认为，是因为自己水平不高。只是在心里想，无法实现现实

提交到kafka的消息可以撤回吗？

1. 它不支持消息回滚。2它可以采用延迟发送策略来实现召回。三。召回策略不能满足实时性要求。取舍在于业务需求

flume和Kafka有一些相同的功能，但总的来说，它们是完全不同的。它们的场景不同，但可以一起使用。

简而言之，flume是一个分布式日志收集系统，它从各种服务器收集日志并将其传输到指定的位置，如HDFS。

Kafka是一个分布式消息中间件，有自己的存储，提供推拉数据访问功能。

整个过程如下：

登录服务器<--flume-->kafka-->hdfs-->离线计算

登录服务器<--flume-->kafka-->storm

希望我的回答能对您有所帮助

日志采集系统flume和kafka有什么区别及联系？

卡夫卡的分布式单元是分区。Kafka保证分区中的数据是有序的，而分区之间的数据不能保证顺序。多分区的特性使Kafka在一定程度上具备了分布式消息传递的能力。

在业务中，我们需要将需要严格排序的数据放在一个分区上，同时，我们需要将可以分发到其他分区的消息放在一个分区上，以确保高性能。

kafka为什么会丢消息 kafka保证消息不重复消费 kafka面试避免重复消费

版权声明：本文内容由互联网用户自发贡献，本站不承担相关法律责任.如有侵权/违法内容,本站将立刻删除。