confluent-kafka-python：パラメータなしのConsumer.commit（）

Question

私は、Consumer.commit(msg=None)を呼び出すことが有効なケースであることに気付きました。少なくともそれは図書館のコードで個別に処理されています。私はそれをしてConsumer.commitと "msg"引数の最後の読み取りメッセージを呼び出すことの違いは何だろうと思っています。

それはほとんど同じことをしているようですが、それでなぜ引数は常にすべてのテストで明示的に渡されますかexamples/integration_test.py？マグナスEdenhillによって回答

Answer 1

https://github.com/confluentinc/confluent-kafka-python/issues/277

：引数レス

（コミット）現在の割り当てのためのすべてのコミットされていないオフセットをコミットします。

Pythonの統合テストは、主にライブブローカ環境でAPIを検証することです。実際のkafkaクライアントテストは、librdkafkaのビルドツリーにあり、より詳細です。 （このPythonクライアントを使用する）librdkafkaは、夜間のジョブで標準のApache Kafkaクライアントシステムテストスイートをすべて実行します。