Java生产者和使用者

Java生产者和使用者

本文介绍了Kafka Java生产者和使用者,其ACL启用了主题的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!

问题描述

我对kafka ACL配置感到困惑,在该配置中我们为生产者和消费者配置了授权.有各种示例显示使用命令行生成/使用消息.我们是否需要任何额外的配置来使用JAVA api来/从安全的kafka主题生成/使用消息.

I'm bit confused with kafka ACL configuration, where we configure authorization for producer and consumer.There are various examples showing producing/consuming message using command line.Do we need any extra configuration to produce/consume messages using JAVA api to/from secured kafka topic.

推荐答案

如果您想了解安全的Kafka服务器的配置详细信息,请融合的文档有一个很好的描述.您会在文档中注意到,您通过文件 client.properties 设置了某些属性,该文件将用作控制台生产者和使用者的配置文件.同样,对于Java使用者/生产者,您可以按照示例此处.

If you would like to learn about the details of configuration for a secured Kafka server, Confluent docs has an excellent description. You can notice in the docs that you set certain properties through a file client.properties, which shall be used as a config file for the console producer and consumer. Similarly in the case of Java consumer/producer, you can set these properties as described in the examples here.

这篇关于Kafka Java生产者和使用者,其ACL启用了主题的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持!

09-06 00:30