[Kafka 常见面试题]如何保证消息的不重复不丢失

Kafka1. Kafka如何保证不丢失消息?生产者数据的不丢失如果是同步模式:ack机制能够保证数据的不丢失,如果ack设置为0,风险很大,一般不建议设置为0。即使设置为1,也会随着leader宕机丢失数据。producer.type=sync request.required.acks=1如果是...

Kafka常见面试题

1 什么是kafkaKafka是分布式发布-订阅消息系统,它最初是由LinkedIn公司开发的,之后成为Apache项目的一部分,Kafka是一个分布式,可划分的,冗余备份的持久性的日志服务,它主要用于处理流式数据。2 为什么要使用 kafka,为什么要使用消息队列缓冲和削峰:上游数据时有突发流量,...

消息队列Kafka入门课程

4 课时 |
3098 人已学 |
免费

分布式消息系统 Kafka 快速入门

24 课时 |
640 人已学 |
免费
开发者课程背景图

Kafka常见面试题

如何防止消息丢失?发送端:ack设置为-1或副本数,默认副本全部同步才会认为发送成功接收端:对接收到的数据进行备份,定期进行检查对执行失败的数据重新执行;选择手动提交offset,对执行失败的数据不提交offset。如何防止消息的重复消费?在消费者端对数据进行幂等校验,禁...

Java面试题 -Kafka

Java面试题 -Kafka

1. 说说kafka:1.消息分类按不同类别,分成不同的Topic,Topic⼜拆分成多个partition,每个partition均衡分散到不同的服务器(提⾼并发访问的能⼒)。2.消费者按顺序从partition中读取,不⽀持随机读取数据,但可通过改变保存到zookeeper中的offset位置实...

最经典的一道JAVA面试题:谈谈你对Kafka零拷贝原理的理解

最经典的一道JAVA面试题:谈谈你对Kafka零拷贝原理的理解

最近一位3年工作经验的小伙伴去某厂面试,被问到这样一个问题,说:”请你简单说一下Kafka的零拷贝原理“。然后,这位小伙伴突然愣住了,什么是零拷贝,零拷贝跟Kafka有关系吗?​那么今天,我给大家来聊一聊我对Kafka零拷贝原理的理解。​另外,我把往期分享的视频全部整理成...

别找了,Kafka视频、书、面试题全给你准备好了~~

别找了,Kafka视频、书、面试题全给你准备好了~~

这是彭文华的第105篇原创Kafka到底有多重要?这么说吧,大数据领域任何一个架构,都缺不了它。作为一个超级消息中间件,它可以用在所有高并发、高吞吐的任何数据场景中。你要是不懂Kafka都不好意思说自己是大数据从业者。日志采集和传输中有它,离线数据处理有它,实时数据处理有它,实时数仓也有它ÿ...

Java 最常见的面试题:使用 kafka 集群需要注意什么?

集群的数量不是越多越好,最好不要超过 7 个,因为节点越多,消息复制需要的时间就越长,整个群组的吞吐量就越低。 集群数量最好是单数,因为超过一半故障集群就不能用了,设置为单数容错率更高。

kafka 面试题

18、kafka 如何不消费重复数据?比如扣款,我们不能重复的扣。其实还是得结合业务来思考,我这里给几个思路:比如你拿个数据要写库,你先根据主键查一下,如果这数据都有了,你就别插入了,update 一下好吧。比如你是写 Redis,那没问题了,反正每次都是 ...

kafka 面试题

14、如何控制消费的位置kafka 使用 seek(TopicPartition, long)指定新的消费位置。用于查找服务器保留的最早和最新的 offset 的特殊的方法也可用(seekToBeginning(Collection) 和seekToEnd(Collection))15、kafka ...

kafka 面试题

13、消费者故障,出现活锁问题如何解决?出现“活锁”的情况,是它持续的发送心跳,但是没有处理。为了预防消费者在这种情况下一直持有分区,我们使用 max.poll.interval.ms 活跃检测机制。 在此基础上,如果你调用的 poll 的频率大于最大间隔,则客户端将主动地离开组,以便...

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

云消息队列 Kafka 版面试题相关内容