元婴期

15. Kafka 如何保证消息的持久性和可靠性？日志段（Log Segment）在其中的作用是什么？

16. Kafka 的压缩机制是什么？如何通过压缩消息来提高 Kafka 的性能？

17. Kafka 的幂等性（Idempotence）和事务性（Transactions）分别如何实现？它们有什么应用场景？

18. Kafka Streams 和 Kafka Connect 是什么？它们分别解决什么问题？

19. Kafka 在高并发场景下如何进行性能优化？有哪些配置需要调整？

20. 如何在 Kafka 中实现数据清理（Log Compaction）？数据清理对性能的影响是什么？

21. Kafka 集群如何扩展？如何添加和移除节点？扩展时需要注意什么？