时间戳

首页 > 解决方案 > 如何为生产者确保 kafka 主题？

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

问题描述

我有多个生产者将消息推送到我的 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

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

谢谢

标签： javaspring-bootsslapache-kafka

解决方案

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

  • SASL
  • SSL
  • 风俗

对于授权，有不同的方式

  • 阿帕奇游侠
  • Kafka 内置 ACL

参考这个文档

推荐阅读