我是Kafka的新人。如果有人能指引我正确的方向，那将是一个很大的帮助。
情况是：
我有一个producer应用程序，它将json数据发送到kafka主题。
我已经实现了一个身份验证服务器。
producer json数据在头中有一个authtoken，在将数据发送到kafka topic之前，需要在auth服务器中验证它。
如果auth服务器验证了authtoken，那么我需要将数据流传输到kafka主题。
我怎样才能实现这个场景。什么是最佳实践。如果我创建一个应用程序来验证数据并将数据发送给kafka，我想这太幼稚了。我正在检查Kafka的安全，但我不明白如何去与这种情况。如有任何有帮助的意见，我们将不胜感激。