インターフェースの使用
org.springframework.kafka.support.Acknowledgment
Acknowledgment を使用するパッケージ
パッケージ
説明
kafka リスナーのためのパッケージ
リスナーを適応させるためのクラスを提供します。
kafka コンバーター用パッケージ
org.springframework.kafka.listener 内の Acknowledgment 使用
型 Acknowledgment のパラメーターを持つ org.springframework.kafka.listener のメソッド修飾子と型メソッド説明default ObjectSEKafkaListenerErrorHandler.handleError(Message<?> message, ListenerExecutionFailedException exception, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, Acknowledgment ack) エラーを処理します。ManualAckListenerErrorHandler.handleError(Message<?> message, ListenerExecutionFailedException exception, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, Acknowledgment ack) voidAcknowledgingConsumerAwareMessageListener.onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K, V> data, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) voidAcknowledgingMessageListener.onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K, V> data, Acknowledgment acknowledgment) kafka からのデータで呼び出されます。voidBatchAcknowledgingConsumerAwareMessageListener.onMessage(ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> data, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) voidBatchAcknowledgingMessageListener.onMessage(ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> data, Acknowledgment acknowledgment) default voidBatchMessageListener.onMessage(org.apache.kafka.clients.consumer.ConsumerRecords<K, V> records, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<K, V> consumer) リスナーは、ConsumerRecordのリストの代わりに、元のConsumerRecordsオブジェクトを受け取ります。default voidGenericMessageListener.onMessage(T data, Acknowledgment acknowledgment) kafka からのデータで呼び出されます。default voidGenericMessageListener.onMessage(T data, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) kafka からのデータで呼び出され、Consumerへのアクセスを提供します。org.springframework.kafka.listener.adapter 内の Acknowledgment 使用
型 Acknowledgment のパラメーターを持つ org.springframework.kafka.listener.adapter のメソッド修飾子と型メソッド説明protected voidMessagingMessageListenerAdapter.acknowledge(Acknowledgment acknowledgment) voidBatchToRecordAdapter.adapt(ListSE<Message<?>> messages, ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> records, Acknowledgment ack, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, BatchToRecordAdapter.Callback<K, V> callback) リストを調整し、各メッセージのコールバックを呼び出します。voidDefaultBatchToRecordAdapter.adapt(ListSE<Message<?>> messages, ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> records, Acknowledgment ack, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, BatchToRecordAdapter.Callback<K, V> callback) protected voidMessagingMessageListenerAdapter.asyncFailure(ObjectSE request, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, ThrowableSE t, Message<?> source) protected voidMessagingMessageListenerAdapter.handleException(ObjectSE records, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, Message<?> message, ListenerExecutionFailedException e) protected voidMessagingMessageListenerAdapter.handleResult(ObjectSE resultArg, ObjectSE request, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, Message<?> source) リスナーメソッドから返された指定された結果オブジェクトを処理し、SendTo トピックにレスポンスメッセージを送信します。voidBatchToRecordAdapter.Callback.invoke(org.apache.kafka.clients.consumer.ConsumerRecord<K, V> record, Acknowledgment ack, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, Message<?> message) 各メッセージを処理します。protected voidMessagingMessageListenerAdapter.invoke(ObjectSE records, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, Message<?> message) protected final ObjectSEMessagingMessageListenerAdapter.invokeHandler(ObjectSE data, Acknowledgment acknowledgment, Message<?> message, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) ハンドラーを呼び出し、専用のエラーメッセージでListenerExecutionFailedExceptionへの例外をラップします。voidBatchMessagingMessageListenerAdapter.onMessage(ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> records, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) KafkaMessageListenerエントリポイント。voidBatchMessagingMessageListenerAdapter.onMessage(org.apache.kafka.clients.consumer.ConsumerRecords<K, V> records, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<K, V> consumer) voidConvertingMessageListener.onMessage(org.apache.kafka.clients.consumer.ConsumerRecord receivedRecord, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer consumer) voidFilteringBatchMessageListenerAdapter.onMessage(ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> data, Acknowledgment acknowledgment) voidFilteringBatchMessageListenerAdapter.onMessage(ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> records, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) voidFilteringMessageListenerAdapter.onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K, V> data, Acknowledgment acknowledgment) voidFilteringMessageListenerAdapter.onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K, V> consumerRecord, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) voidKafkaBackoffAwareMessageListenerAdapter.onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K, V> data, Acknowledgment acknowledgment) voidKafkaBackoffAwareMessageListenerAdapter.onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K, V> consumerRecord, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) voidRecordMessagingMessageListenerAdapter.onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K, V> record, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) KafkaAcknowledgingConsumerAwareMessageListenerエントリポイント。protected Message<?>BatchMessagingMessageListenerAdapter.toMessagingMessage(ListSE records, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) protected Message<?>MessagingMessageListenerAdapter.toMessagingMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K, V> cRecord, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) org.springframework.kafka.support.converter 内の Acknowledgment 使用
型 Acknowledgment のパラメーターを持つ org.springframework.kafka.support.converter のメソッド修飾子と型メソッド説明default voidMessageConverter.commonHeaders(Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, MapSE<StringSE, ObjectSE> rawHeaders, ObjectSE theKey, ObjectSE topic, ObjectSE partition, ObjectSE offset, ObjectSE timestampType, ObjectSE timestamp) 共通ヘッダーを設定します。Message<?>BatchMessageConverter.toMessage(ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>> records, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, TypeSE payloadType) ConsumerRecordのリストをMessageに変換します。Message<?>BatchMessagingMessageConverter.toMessage(ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<?, ?>> records, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, TypeSE type) Message<?>MessagingMessageConverter.toMessage(org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> record, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, TypeSE type) Message<?>RecordMessageConverter.toMessage(org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> record, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, TypeSE payloadType) ConsumerRecordをMessageに変換します。