kafkaクラスタを管理するためのPythonライブラリ

Question

インターネットでpythonライブラリを検索し、トピック、パーティション増分、パーティション再割り当て、リーダー選挙などCRUDのようなkafka操作を管理しました。何も見つけられません。

私はpykafka、kafka-pythonを知っていますが、それらは消費者/プロデューサを作成するためのものです。私はトピックでCRUDにkazooを使用できますが、私は言及した他の操作を実行できません。あなたはkafkaクラスタ（利用可能な場合）を管理するための任意のpythonライブラリを提案できますか？

ありがとうございます！

Answer 1

PyKafkaにトピックを作成するためのCLIが含まれていますhere。私はあなたが "パーティション増分"とは何を意味するのか分かりません。コンシューマへのパーティションの割り当ては、PyKafkaのメンバーシッププロトコル実装によって内部的に処理されます。リーダーの選挙は、私の知る限りでは、クライアントによって引き起こされるものではありません。

私は、KafkaにバンドルされているCLIツールの機能を完全に再現するPythonライブラリについては知らないが、PyKafkaは近づいてきている。