[我正在尝试寻找一种方法来使用由websocket发送到kafka主题的消息（消息由websocket发送到地址'ws：// address：port / topic_name'，我想添加所有到kafka主题的邮件中）。我阅读了有关kafka connect的文章，并试图找到一种使用它的方法，但是它似乎不起作用...在此先感谢：）
Kafka connect的想法是，您具有某种外部存储集成功能。可以是SAP，Salesforce，RDBMS，MQ或其他任何具有状态的东西。您的websocket端点没有状态，您无法对其进行轮询，因为其他人正在调用它，因此状态已转移。现在，如果您知道实际上是谁拥有该州，则可以使用本指南潜在地建立一个收藏家。 https://docs.confluent.io/current/connect/devguide.html
对于您的特定情况，最好的办法是使用Kafka Producer APIhttps://docs.confluent.io/current/clients/producer.html并从您的websocket中指定使用此生产者将消息发布到主题，或者甚至更好（如果您使用的是spring），则可以使用更高级别的抽象，即KafkaTemplate https://docs.spring.io/spring-kafka/reference/html/#sending-messages。