Java 类org.apache.kafka.clients.consumer.internals.ConsumerCoordinator 实例源码

KafkaConsumer(String clientId,
              ConsumerCoordinator coordinator,
              Deserializer<K> keyDeserializer,
              Deserializer<V> valueDeserializer,
              Fetcher<K, V> fetcher,
              ConsumerInterceptors<K, V> interceptors,
              Time time,
              ConsumerNetworkClient client,
              Metrics metrics,
              SubscriptionState subscriptions,
              Metadata metadata,
              long retryBackoffMs,
              long requestTimeoutMs) {
    this.clientId = clientId;
    this.coordinator = coordinator;
    this.keyDeserializer = keyDeserializer;
    this.valueDeserializer = valueDeserializer;
    this.fetcher = fetcher;
    this.interceptors = interceptors;
    this.time = time;
    this.client = client;
    this.metrics = metrics;
    this.subscriptions = subscriptions;
    this.metadata = metadata;
    this.retryBackoffMs = retryBackoffMs;
    this.requestTimeoutMs = requestTimeoutMs;
}

KafkaConsumer(String clientId,
              ConsumerCoordinator coordinator,
              Deserializer<K> keyDeserializer,
              Deserializer<V> valueDeserializer,
              Fetcher<K, V> fetcher,
              ConsumerInterceptors<K, V> interceptors,
              Time time,
              ConsumerNetworkClient client,
              Metrics metrics,
              SubscriptionState subscriptions,
              Metadata metadata,
              long retryBackoffMs,
              long requestTimeoutMs) {
    this.clientId = clientId;
    this.coordinator = coordinator;
    this.keyDeserializer = keyDeserializer;
    this.valueDeserializer = valueDeserializer;
    this.fetcher = fetcher;
    this.interceptors = interceptors;
    this.time = time;
    this.client = client;
    this.metrics = metrics;
    this.subscriptions = subscriptions;
    this.metadata = metadata;
    this.retryBackoffMs = retryBackoffMs;
    this.requestTimeoutMs = requestTimeoutMs;
}