Class MetadataServiceCoordinator

java.lang.Object
org.apache.kafka.clients.consumer.internals.AbstractCoordinator
io.confluent.security.store.kafka.coordinator.MetadataServiceCoordinator
All Implemented Interfaces:
Closeable, AutoCloseable
public class MetadataServiceCoordinator extends org.apache.kafka.clients.consumer.internals.AbstractCoordinator
Coordinator for the Metadata Service used to track active nodes and elect master writer.

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final String
    PROTOCOL
     

    Fields inherited from class org.apache.kafka.clients.consumer.internals.AbstractCoordinator

    HEARTBEAT_THREAD_PREFIX, JOIN_GROUP_TIMEOUT_LAPSE

  • Constructor Summary

    Constructors
    Constructor
    Description
    MetadataServiceCoordinator(org.apache.kafka.common.utils.LogContext logContext, org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient client, NodeMetadata nodeMetadata, org.apache.kafka.clients.consumer.ConsumerConfig consumerConfig, org.apache.kafka.common.metrics.Metrics metrics, String metricGrpPrefix, org.apache.kafka.common.utils.Time time, MetadataServiceRebalanceListener rebalanceListener)
     

  • Method Summary

    Methods inherited from class org.apache.kafka.clients.consumer.internals.AbstractCoordinator

    close, coordinatorUnknown, ensureActiveGroup, maybeLeaveGroup, requestRejoin, requestRejoin, requestRejoinIfNecessary

    Methods inherited from class java.lang.Object

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

  • Field Details

  • Constructor Details

    • MetadataServiceCoordinator

      public MetadataServiceCoordinator(org.apache.kafka.common.utils.LogContext logContext, org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient client, NodeMetadata nodeMetadata, org.apache.kafka.clients.consumer.ConsumerConfig consumerConfig, org.apache.kafka.common.metrics.Metrics metrics, String metricGrpPrefix, org.apache.kafka.common.utils.Time time, MetadataServiceRebalanceListener rebalanceListener)