kafka是怎么保证数据高可靠的？

1、数据复制：Kafka允许为每个主题的分区设置多个副本，这些副本分布在不同的Broker上，当某个Broker出现故障时，其他副本可以继续提供服务，保证数据的可用性和完整性。
2、ACK确认：生产者发送消息后，可以配置不同的确认级别（acks）。例如，acks=all表示只有当所有的副本都成功写入消息后，生产者才会收到确认，确保消息不会因为部分副本写入失败而丢失。
3、数据持久化：Kafka将消息写入磁盘，并通过配置合理的日志保留策略，如log.retention.hours等参数，来确保数据在磁盘上保存足够长的时间，以便在需要时进行恢复。
4、幂等性：生产者在发送消息时可以设置幂等性，保证即使在出现网络故障等情况下，相同的消息也不会被重复写入Kafka，避免数据重复和不一致。