問題タブ [apache-kafka-streams]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票する
1 に答える
6341 参照

apache-kafka - Kafka Streams DSL を使用するときにエラーを処理してコミットしない方法

Kafka ストリームの場合、下位レベルのプロセッサ API を使用すると、コミットするかどうかを制御できます。したがって、コードで問題が発生し、このメッセージをコミットしたくない場合。この場合、問題が修正されるまで Kafka はこのメッセージを複数回再配信します。

しかし、その上位レベルのストリーム DSL API を使用するときに、メッセージをコミットするかどうかを制御するにはどうすればよいでしょうか?

資力:

http://docs.confluent.io/2.1.0-alpha1/streams/developer-guide.html