一、Kafka中数据是怎么传输的？Kafka中数据传输分为三步： Producer端将消息发送给Broker Broker端将消息进行同步并持久化 Consumer端从Broker将消息拉取并消费 二、Kafka如何保证数据不丢失？因为

一、为什么会出现重复消费的问题？ 一个消费者组有多个消费者，每条消息只会被某个消费者的某个分区消费，如果没有正常提交offset，就会导致后续重复拉取到该消息而重复消费 超过max.poll.interval.ms时间还没消费完就会触发重平

一、什么是Kafka的副本机制？Kafka的副本机制，也就是备份机制，指在分布式集群中每个节点都同步了相同的数据备份。 二、Kafka的副本机制有什么用？Kafka的副本机制是保证消息可靠性的重要手段之一，它可以： 提高可用性：每个top

一、什么是Kafka的重平衡机制？Kafka的重平衡（Rebalance）机制指的是消费者组（Consumer Group）新增或删除消费者（Consumer）时，Kafka集群会重新分配topic分区给各个消费者，以保证每个消费者消费的分

一、什么是消息队列？消息队列（Message Queue），简称MQ，是一种应用间的通信方式，主要由三部分组成： 生产者（Producer）：负责消息发送 代理（Broker）：负责消息存储 消费者（Consumer）：负责消息消费 二

一、什么是缓存命中率？如果我们使用redis作为缓存数据库，一般会用缓存命中率来评判对系统的性能（抗并发性）有多大的提升。通常来说，命中率越高，表示使用缓存效果越高，同时系统性能越好、抗并发能力越强。 缓存命中率指的是客户端查询语句查询re

一、什么是热点key呢？热点key指的是频繁访问的key，比如明星八卦带来的微博热搜、双十一带来的秒杀活动等，都很容易出现热点key。 热点key带来的问题也很明显，就比如突然的微博热搜导致微博卡顿、宕机的情况，就是因为热点key被频繁访问

一、SQL的执行过程 执行SQL语句： select * from student A where age = 18 and name = 'Gary'; 步骤如下： 通过客户端/服务器通信协议与MySQL建立连接，并查询是否有权限 My

一、MongoDB和MySQL有什么区别？ MongoDB MySQL 数据库类型 非关系型 关系型 存储方式 JSON 列+行存储 扩展性 支持分布式部署，可以动态扩展集群 需要横向分表或纵向扩容来解决数据量过大的问题

一、synchronized的锁优化包括哪些？synchronized的锁优化主要包括： 自旋锁 锁清除 锁粗化 … 二、synchronized的锁优化过程1、自旋锁例子：比如我们去银行取钱，我们有两种方式如下： 站在取款机前排队等

一、synchronized锁变化历程 在JDK 1.6及之前的版本中，synchronized锁是通过对象内部的一个叫做监视器锁monitor（也称对象锁）来实现的。当一个线程请求对象锁时，如果该对象没有被锁住，线程就会获取锁并继续执行。

一、synchronized和ReentrantLock有什么区别？synchronized和ReentrantLock的区别有以下几点： 底层实现：synchronized是Java关键字，ReentrantLock是Java API