我是Kafka世界的新人。我们计划建立Kafka来满足我们的数据流需求。在我们的例子中，Flume是静止的端点。有哪些连接器支持kafka=>rest端点连接？这类似于aws简单队列或主题的工作方式。
piv4azn71#
我知道没有现成的东西，但是akka streams感觉非常适合这个用例。源将是使用akka stream kafka（aka reactive kafka）和akka http客户端（基于流的变体）的接收器创建的kafka消息流：http://doc.akka.io/docs/akka-http/10.0.6/scala/http/client-side/request-level.html#flow-基于变量akka流的集成模式（开始）以alpakka的名称记录：http://developer.lightbend.com/docs/alpakka/current/
gorkyyrv2#
afaik apache kafka没有经过认证的http接收器。为什么不简单地创建一个kafka消费者并为每个消息（或消息批处理）对您的服务进行rest调用呢？
2条答案
按热度按时间piv4azn71#
我知道没有现成的东西，但是akka streams感觉非常适合这个用例。
源将是使用akka stream kafka（aka reactive kafka）和akka http客户端（基于流的变体）的接收器创建的kafka消息流：http://doc.akka.io/docs/akka-http/10.0.6/scala/http/client-side/request-level.html#flow-基于变量
akka流的集成模式（开始）以alpakka的名称记录：http://developer.lightbend.com/docs/alpakka/current/
gorkyyrv2#
afaik apache kafka没有经过认证的http接收器。为什么不简单地创建一个kafka消费者并为每个消息（或消息批处理）对您的服务进行rest调用呢？