org.springframework.kafka.core

Class ProducerFactoryUtils

java.lang.Object

org.springframework.kafka.core.ProducerFactoryUtils

public final class ProducerFactoryUtils
extends java.lang.Object

Helper class for managing a Spring based Kafka DefaultKafkaProducerFactory in particular for obtaining transactional Kafka resources for a given ProducerFactory.

Mainly for internal use within the framework.

Author:

Gary Russell

Method Summary

Modifier and Type	Method and Description
static void	clearConsumerGroupId() Clear the group id for the consumer bound to this thread.
static java.lang.String	getConsumerGroupId() Get the group id for the consumer bound to this thread.
static <K,V> KafkaResourceHolder<K,V>	getTransactionalResourceHolder(ProducerFactory<K,V> producerFactory) Obtain a Producer that is synchronized with the current transaction, if any.
static <K,V> void	releaseResources(KafkaResourceHolder<K,V> resourceHolder)
static void	setConsumerGroupId(java.lang.String groupId) Set the group id for the consumer bound to this thread.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getTransactionalResourceHolder

public static <K,V> KafkaResourceHolder<K,V> getTransactionalResourceHolder(ProducerFactory<K,V> producerFactory)

Obtain a Producer that is synchronized with the current transaction, if any.

Type Parameters:

K - the key type.

V - the value type.

Parameters:

producerFactory - the ConnectionFactory to obtain a Channel for

Returns:

the resource holder.

releaseResources

public static <K,V> void releaseResources(KafkaResourceHolder<K,V> resourceHolder)

setConsumerGroupId

public static void setConsumerGroupId(java.lang.String groupId)

Set the group id for the consumer bound to this thread.

Parameters:

groupId - the group id.

Since:

1.3

getConsumerGroupId

public static java.lang.String getConsumerGroupId()

Get the group id for the consumer bound to this thread.

Returns:

the group id.

Since:

1.3

clearConsumerGroupId

public static void clearConsumerGroupId()

Clear the group id for the consumer bound to this thread.

Since:

1.3