我有一个web服务器，它接收一些事件作为post请求，我想使用kafka流进行处理。我可以使用哪个源连接器来实现这一点？
jtw3ybtb1#
源连接器从源（本例中是您的服务器）读取数据，这将是get请求。。。如果您希望从connect发出post请求（使用kafka然后发送请求），那么这将是一个sink连接器，与kafka流无关相关：https://github.com/llofberg/kafka-connect-rest如果这不能满足您的需要，您可以编写自己的连接器
1条答案
按热度按时间jtw3ybtb1#
源连接器从源（本例中是您的服务器）读取数据，这将是get请求。。。
如果您希望从connect发出post请求（使用kafka然后发送请求），那么这将是一个sink连接器，与kafka流无关
相关：https://github.com/llofberg/kafka-connect-rest
如果这不能满足您的需要，您可以编写自己的连接器