Index

A B C D E F G H I J K L M N O P R S T U V W Z
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

W

waitForAssignment(Object, int) - Static method in class org.springframework.kafka.test.utils.ContainerTestUtils

Wait until the container has the required number of assigned partitions.

waitForAssignment(Duration) - Method in interface org.springframework.kafka.requestreply.ReplyingKafkaOperations

Wait until partitions are assigned, e.g.

waitForAssignment(Duration) - Method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate

wantsPollResult() - Method in class org.springframework.kafka.listener.adapter.BatchMessagingMessageListenerAdapter

wantsPollResult() - Method in interface org.springframework.kafka.listener.BatchMessageListener

Return true if this listener wishes to receive the original ConsumerRecords object instead of a list of ConsumerRecord.

WARN - Enum constant in enum class org.springframework.kafka.KafkaException.Level

Warn.

WARN - Enum constant in enum class org.springframework.kafka.support.LogIfLevelEnabled.Level

Warn.

wrap(Message<?>) - Static method in class org.springframework.kafka.support.KafkaMessageHeaderAccessor

Create an instance from the payload and headers of the given Message.

A B C D E F G H I J K L M N O P R S T U V W Z
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form