正如标题所示，我正在寻找一种方法来限制Kafka消费者将数据发布到我的Kafka主题中。例如，我们可以在数据库中设置只读用户。
我的用例要求我从一些供应商那里获取数据，丰富这些数据并将其发布到我们的kafka主题中。本主题中的数据将由少数消费者读取。据我所知，我必须向消费者提供相同的用户名和密码（生产商正在使用的用户名和密码）。那么有没有办法阻止消费者在Kafka主题中发布数据呢。
e、 g:基于用户名/ip地址限制。