Kafka开启SASL安全认证以及配置ACL权限控制 本篇介绍kafka配置安全认证SASL以及ACL权限控制,并使用控制台和python访问开启了SASL认证的kafka集群。 2022-10-27 浏览(3033) 阅读全文
Kafka消费者策略、Rebalance机制、Offset存储机制 本篇介绍kafka消费者策略,分区分配策略,Rebalance重分配策略,以及offset存储机制 2022-10-27 浏览(1278) 阅读全文
Kafka生产者分区策略、ISR、ACK、幂等性、事务机制 本篇介绍kafka生产者的分区策略、ISR、ACK机制,故障处理,一致性语义,Exactly Once精准一次性语义等 2022-10-27 浏览(1166) 阅读全文
kafka UniformTransactionsGenerator 源码 kafka UniformTransactionsGenerator 代码 文件路径:/trogdor/src/main/java/org/apache/kafka/trogdor/workload/UniformTransactionsGenerator.java 2022-10-20 浏览(691) 阅读全文
kafka UniformRandomPayloadGenerator 源码 kafka UniformRandomPayloadGenerator 代码 文件路径:/trogdor/src/main/java/org/apache/kafka/trogdor/workload/UniformRandomPayloadGenerator.java 2022-10-20 浏览(680) 阅读全文
kafka TransactionGenerator 源码 kafka TransactionGenerator 代码 文件路径:/trogdor/src/main/java/org/apache/kafka/trogdor/workload/TransactionGenerator.java 2022-10-20 浏览(769) 阅读全文