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