A、在 kafka 的 ack 机制中,如果把参数 request.required.acks设置成 -1 就能保证数据不丢失。
B、Kafka 把 topic 中一个 partition 大文件分成多个小文件段,通过多个小文件段,就容易定期清除或删除已经消费完文件,减少磁盘占用。
C、ISR是一组与leaders完全同步的消息副本,也就是说ISR中包含了所有提交的消息。ISR应该总是包含所有的副本,直到出现真正的故障。如果一个副本从leader中脱离出来,将会从 ISR 中删除。
D、创建的 kafka 的 Topic 为了能应对复杂的业务需求场景,已存在的 Topic 可以增加或者减少分区