インターフェース BatchToRecordAdapter.Callback<K,V>
- 型パラメーター:
K
- 鍵の型。V
- 値の型。
- 含まれているインターフェース:
- BatchToRecordAdapter<K,
V>
- 関数インターフェース:
- これは関数インターフェースであるため、ラムダ式またはメソッド参照の割り当てターゲットとして使用できます。
各メッセージのコールバック。
メソッドのサマリー
修飾子と型メソッド説明void
invoke
(org.apache.kafka.clients.consumer.ConsumerRecord<K, V> record, Acknowledgment ack, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, Message<?> message) 各メッセージを処理します。
メソッドの詳細
invoke
void invoke(org.apache.kafka.clients.consumer.ConsumerRecord<K, V> record, Acknowledgment ack, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, Message<?> message) 各メッセージを処理します。- パラメーター:
record
- レコード。ack
- 承認。consumer
- コンシューマー。message
- メッセージ。