Package org.apache.kafka.clients.admin.internals

Class FenceProducersHandler

java.lang.Object

org.apache.kafka.clients.admin.internals.AdminApiHandler.Unbatched<CoordinatorKey,org.apache.kafka.common.utils.ProducerIdAndEpoch>

org.apache.kafka.clients.admin.internals.FenceProducersHandler

All Implemented Interfaces:

AdminApiHandler<CoordinatorKey,org.apache.kafka.common.utils.ProducerIdAndEpoch>

public class FenceProducersHandler
extends AdminApiHandler.Unbatched<CoordinatorKey,org.apache.kafka.common.utils.ProducerIdAndEpoch>

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.kafka.clients.admin.internals.AdminApiHandler

AdminApiHandler.ApiResult<K,V>, AdminApiHandler.Batched<K,V>, AdminApiHandler.RequestAndKeys<K>, AdminApiHandler.Unbatched<K,V>

Constructor Summary

Constructors

Constructor	Description
FenceProducersHandler(org.apache.kafka.common.utils.LogContext logContext)

Method Summary

Modifier and Type	Method	Description
String	apiName()	Get a user-friendly name for the API this handler is implementing.
AdminApiHandler.ApiResult<CoordinatorKey,org.apache.kafka.common.utils.ProducerIdAndEpoch>	handleSingleResponse(org.apache.kafka.common.Node broker, CoordinatorKey key, org.apache.kafka.common.requests.AbstractResponse abstractResponse)
AdminApiLookupStrategy<CoordinatorKey>	lookupStrategy()	Get the lookup strategy that is responsible for finding the brokerId which will handle each respective key.
static AdminApiFuture.SimpleAdminApiFuture<CoordinatorKey,org.apache.kafka.common.utils.ProducerIdAndEpoch>	newFuture(Collection<String> transactionalIds)

Methods inherited from class org.apache.kafka.clients.admin.internals.AdminApiHandler.Unbatched

buildRequest, handleResponse

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.kafka.clients.admin.internals.AdminApiHandler

handleUnsupportedVersionException

Constructor Details

FenceProducersHandler

public FenceProducersHandler(org.apache.kafka.common.utils.LogContext logContext)

Method Details

newFuture

public static AdminApiFuture.SimpleAdminApiFuture<CoordinatorKey,org.apache.kafka.common.utils.ProducerIdAndEpoch> newFuture(Collection<String> transactionalIds)

apiName

public String apiName()

Description copied from interface: AdminApiHandler

Get a user-friendly name for the API this handler is implementing.

lookupStrategy

public AdminApiLookupStrategy<CoordinatorKey> lookupStrategy()

Description copied from interface: AdminApiHandler

Get the lookup strategy that is responsible for finding the brokerId which will handle each respective key.

Returns:

non-null lookup strategy

handleSingleResponse

public AdminApiHandler.ApiResult<CoordinatorKey,org.apache.kafka.common.utils.ProducerIdAndEpoch> handleSingleResponse(org.apache.kafka.common.Node broker,
 CoordinatorKey key,
 org.apache.kafka.common.requests.AbstractResponse abstractResponse)