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.

WakingKafkaConsumerTimingAdjuster - Class in org.springframework.kafka.listener

Adjusts timing by creating a thread that will wakeup the consumer from polling, considering that, if consumption is paused, it will check for consumption resuming in increments of 'pollTimeout'.

WakingKafkaConsumerTimingAdjuster(TaskExecutor) - Constructor for class org.springframework.kafka.listener.WakingKafkaConsumerTimingAdjuster

WakingKafkaConsumerTimingAdjuster(TaskExecutor, Sleeper) - Constructor for class org.springframework.kafka.listener.WakingKafkaConsumerTimingAdjuster

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.

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