1 kafka整体介绍
详解
2 kafka 安装记录
详解
3 kafka安全认证
在 Kafka 0.9.0 以后的版本,添加了安全相关的功能,包括以下:
支持SSL和SASL两种认证方式,其中SASL框架支持 GSSAPI 、PLAIN 、SCRAM-SHA-256 、OAUTHBEARER 等多种认证引擎。认证发生在:client-broker,broker之间,broker-zookeeper。 支持使用SSL进行数据传输加密。 支持client对topic的读写授权。 支持授权服务可插拔,并且支持与外部授权服务(比如sentry)的集成。
最为常用的是SASl/PLAN(用户密码 配置方式)。
4 密码登录的几种方式
java程序如何配置,进行登录。 详解
5 生产者 消费者
kafka 创建生产者时可以指定分区生产消息,不指定默认有分区器计算key分配。
消费者可以指定分区消费,不指定默认从所有分区获取;同一组的消费者,只要一个消费了消息A,该组的其他成员不会再消费。
生产者的close方法不能马上断开连接,官方没有提供马上断开的接口,除非你关闭程序。
生产者send发送方法,方法同步异步介绍。