我希望所有Kafka主题中的记录都插入到dynamodb中。有没有开源插件可以做同样的事情。或者有没有其他更好的方法可以在dynamodb本身中实现呢。请建议洛克什·纳拉扬
lokaqttq1#
在dynamodb中存储kafka消息是kafka connect的一个很好的用例。不幸的是，我不知道任何现成的接收器连接器dynamodb。你可以在这里看到一个列表。现在，您需要构建自己的sink连接器（希望是开源的！）或者构建一个写入dynamodb的自定义使用者。
lrl1mhuk2#
然而，我发现这个Kafka连接发电机。虽然它目前还没有维护，但它对我起了作用。
2条答案
按热度按时间lokaqttq1#
在dynamodb中存储kafka消息是kafka connect的一个很好的用例。不幸的是，我不知道任何现成的接收器连接器dynamodb。你可以在这里看到一个列表。现在，您需要构建自己的sink连接器（希望是开源的！）或者构建一个写入dynamodb的自定义使用者。
lrl1mhuk2#
然而，我发现这个Kafka连接发电机。虽然它目前还没有维护，但它对我起了作用。