java - 如何为生产者确保 kafka 主题？

Question

我有多个生产者将消息推送到我的 kafka 代理中。想要保护我的主题，以便生产者需要密码才能在主题中推送消息或任何类型的保护。
在 spring boot 中必须看到以下属性。

spring.cloud.stream.kafka.binder.configuration.[security.protocol]=SSL
#spring.cloud.stream.kafka.binder.configuration.[ssl.truststore.location]=D:\\streaming\\MessagingQueingTier\\SSL\\kafka.client.truststore.jks
#spring.cloud.stream.kafka.binder.configuration.[ssl.truststore.password]=clientpass
#spring.cloud.stream.kafka.binder.configuration.[ssl.keystore.location]=D:\\streaming\\MessagingQueingTier\\SSL\\kafka.client.keystore.jks
#spring.cloud.stream.kafka.binder.configuration.[ssl.keystore.password]=clientpass
#spring.cloud.stream.kafka.binder.configuration.[ssl.key.password]=clientpass

这些属性对满足我的要求有用吗？以及如何设置这些属性？
无法理解。任何人都可以帮助或分享任何引用文档吗？
谢谢

Answer 1

请参阅 Kafka 安全性文档。有很多方法可以保护 Kafka:

SASL

SSL

定制

对于授权，有不同的方式

Apache 游侠

Kafka 内置 ACL

引用这个 doc