Uses of Class
org.springframework.kafka.support.TopicPartitionOffset

Packages that use TopicPartitionOffset

Package	Description
org.springframework.kafka.annotation	Package for kafka annotations
org.springframework.kafka.config	Package for kafka configuration
org.springframework.kafka.core	Package for kafka core components
org.springframework.kafka.listener	Package for kafka listeners

Uses of TopicPartitionOffset in org.springframework.kafka.annotation

Methods in org.springframework.kafka.annotation with parameters of type TopicPartitionOffset

Modifier and Type	Method	Description
protected void	KafkaListenerAnnotationBeanPostProcessor.processListener(MethodKafkaListenerEndpoint<?,?> endpoint, KafkaListener kafkaListener, Object bean, String beanName, String[] topics, TopicPartitionOffset[] tps)

Uses of TopicPartitionOffset in org.springframework.kafka.config

Methods in org.springframework.kafka.config that return TopicPartitionOffset

Modifier and Type	Method	Description
TopicPartitionOffset[]	AbstractKafkaListenerEndpoint.getTopicPartitionsToAssign()	Return the topicPartitions for this endpoint.
TopicPartitionOffset[]	KafkaListenerEndpoint.getTopicPartitionsToAssign()	Return the topicPartitions for this endpoint.

Methods in org.springframework.kafka.config with parameters of type TopicPartitionOffset

Modifier and Type	Method	Description
C	AbstractKafkaListenerContainerFactory.createContainer(TopicPartitionOffset... topicsAndPartitions)
C	KafkaListenerContainerFactory.createContainer(TopicPartitionOffset... topicPartitions)	Create and configure a container without a listener; used to create containers that are not used for KafkaListener annotations.
void	AbstractKafkaListenerEndpoint.setTopicPartitions(TopicPartitionOffset... topicPartitions)	Set the topicPartitions to use.

Uses of TopicPartitionOffset in org.springframework.kafka.core

Method parameters in org.springframework.kafka.core with type arguments of type TopicPartitionOffset

Modifier and Type	Method	Description
default org.apache.kafka.clients.consumer.ConsumerRecords<K,V>	KafkaOperations.receive(Collection<TopicPartitionOffset> requested)	Receive a multiple records with the default poll timeout (5 seconds).
org.apache.kafka.clients.consumer.ConsumerRecords<K,V>	KafkaOperations.receive(Collection<TopicPartitionOffset> requested, Duration pollTimeout)	Receive multiple records.
default org.apache.kafka.clients.consumer.ConsumerRecords<K,V>	KafkaOperations2.receive(Collection<TopicPartitionOffset> requested)	Deprecated, for removal: This API element is subject to removal in a future version. Receive a multiple records with the default poll timeout (5 seconds).
org.apache.kafka.clients.consumer.ConsumerRecords<K,V>	KafkaOperations2.receive(Collection<TopicPartitionOffset> requested, Duration pollTimeout)	Deprecated, for removal: This API element is subject to removal in a future version. Receive multiple records.
org.apache.kafka.clients.consumer.ConsumerRecords<K,V>	KafkaTemplate.receive(Collection<TopicPartitionOffset> requested, Duration pollTimeout)

Uses of TopicPartitionOffset in org.springframework.kafka.listener

Methods in org.springframework.kafka.listener that return TopicPartitionOffset

Modifier and Type	Method	Description
TopicPartitionOffset[]	ConsumerProperties.getTopicPartitions()	Return the configured TopicPartitionOffsets.

Methods in org.springframework.kafka.listener with parameters of type TopicPartitionOffset

Modifier and Type	Method	Description
default int	CommonErrorHandler.deliveryAttempt(TopicPartitionOffset topicPartitionOffset)
int	CommonMixedErrorHandler.deliveryAttempt(TopicPartitionOffset topicPartitionOffset)
int	DeliveryAttemptAware.deliveryAttempt(TopicPartitionOffset topicPartitionOffset)	Return the next delivery attempt for the topic/partition/offset.
int	FailedRecordProcessor.deliveryAttempt(TopicPartitionOffset topicPartitionOffset)

Constructors in org.springframework.kafka.listener with parameters of type TopicPartitionOffset

Modifier	Constructor	Description
	ConsumerProperties(TopicPartitionOffset... topicPartitions)	Create properties for a container that will assign itself the provided topic partitions.
	ContainerProperties(TopicPartitionOffset... topicPartitions)	Create properties for a container that will assign itself the provided topic partitions.