config目录下创建kafka_server_jaas.conf文件:内容如下:
网站建设哪家好,找创新互联建站!专注于网页设计、网站建设、微信开发、小程序开发、集团企业网站建设等服务项目。为回馈新老客户创新互联还提供了吉林免费建站欢迎大家使用!
KafkaServer {
org.apache.kafka.common.security.plain.PlainLoginModule required
username="admin"
password="admin-secret"
user_admin="admin-secret"
user_alice="alice-secret";
};
config目录下创建kafka_client_jaas.conf文件:内容如下:
KafkaClient {
org.apache.kafka.common.security.plain.PlainLoginModule required
username="alice"
password="alice-secret";
};
3. 修改config目录下的server.properties文件:
修改内容:自定义log.dirs(从新定义日志文件)
log.dirs=D:/kafka_2.10-0.9.0.0/kafka_2.10-0.10.1.0/kafka-logs
添加内容:
#advertised.listeners=PLAINTEXT://192.168.66.119:9092
listeners=SASL_PLAINTEXT://localhost:9092
security.inter.broker.protocol=SASL_PLAINTEXT
sasl.mechanism.inter.broker.protocol=PLAIN
sasl.enabled.mechanisms=PLAIN
#配置这个会报org.apache.kafka.common.errors.GroupAuthorizationException: Not authorized to access group:这个是授权配置的
#authorizer.class.name = kafka.security.auth.SimpleAclAuthorizer
allow.everyone.if.no.acl.found=false
4. config目录下的consumer.properties和producer.properties添加如下内容:
security.protocol=SASL_PLAINTEXT
sasl.mechanism=PLAIN
5. \bin\windows目录下的kafka-server-start.bat文件添加内容如下:
set KAFKA_OPTS=-Djava.security.auth.login.config=D:/kafka_2.10-0.9.0.0/kafka_2.10-0.10.1.0/config/kafka_server_jaas.conf
6. \bin\windows目录下的kafka-console-producer.bat和kafka-console-consumer.bat文件添加内容如下:
set KAFKA_OPTS=-Djava.security.auth.login.config=D:/kafka_2.10-0.9.0.0/kafka_2.10-0.10.1.0/config/kafka_client_jaas.conf
-------------------- 基本的配置已经完成, 现在开始逐个启动----------------------------------
7. 启动kafka自带的zookeeper:
在\bin\windows目录下:shit+右键:弹出框后点击(在此处打开命令窗口), 输入命令:zkserver
8. 启动kafka
在kafka根目录下:shit+右键:弹出框后点击(在此处打开命令窗口), 输入命令:
.\bin\windows\kafka-server-start.bat .\config\server.properties
9. 创建主题:
在\bin\windows目录下:shit+右键:弹出框后点击(在此处打开命令窗口), 输入命令:
kafka-topics.bat--create--zookeeperlocalhost:2181--replication-factor1--partitions1--topictest
10. 创建一个生产者:
在\bin\windows目录下:shit+右键:弹出框后点击(在此处打开命令窗口), 输入命令:
kafka-console-producer.bat --broker-list localhost:9092 --topic test --producer.config D:/kafka_2.10-0.9.0.0/kafka_2.10-0.10.1.0/config/producer.properties
11. 创建一个消费者:
在\bin\windows目录下:shit+右键:弹出框后点击(在此处打开命令窗口), 输入命令:
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning --consumer.config D:/kafka_2.10-0.9.0.0/kafka_2.10-0.10.1.0/config/consumer.properties
12. 在生产者的命令窗口随意输入, 回车发送信息, 在消费者窗口查看接收的消息