我的管道是：
kerberized kafka-->日志存储（托管在不同的服务器上）-->splunk。
我可以用kafka connect替换logstash组件吗？
你能给我指一个资源/指南，在那里我可以使用kerberized kafka作为我的kafka connect（单独托管）的源代码吗？
从文档中，我了解到，如果kafka connect与kafka托管在同一个集群上，这是完全可能的。但是我现在没有这个选择，因为我们的kafka集群是多租户的，因此不允许在集群上进行额外的进程。