Произошло то, о чем говорили уже много лет: для Кафки теперь н | middlejava
Произошло то, о чем говорили уже много лет: для Кафки теперь не нужен ZooKeeper, в общем новость следующая:
Вышла Apache Kafka 2.8.0 Состав вошедших KIP - ниже
KIP-500: Replace ZooKeeper with a self-managed quorum KIP-700: Add Describe Cluster API KIP-684: Support mutual TLS authentication on SASL_SSL listeners KIP-676: Respect logging hierarchy KIP-673: Emit JSONs with new auto-generated schema KIP-612: Limit broker connection creation rate KIP-516: Topic identifiers KIP-661: Expose task configurations in Connect REST API KIP-696: Update Streams FSM to clarify ERROR state meaning KIP-689: Extend StreamJoined to allow more store configs KIP-680: TopologyTestDriver should not require a properties argument KIP-671: Introduce Kafka Streams specific uncaught exception handler KIP-659: Improve TimeWindowedDeserializer and TimeWindowedSerde to handle window size KIP-572: Improve timeouts and retries in Kafka Streams