class KafkaConsumer implements Consumer<K, V> {

    @Override
    public void close() {
        acquire();
        try {
            if (closed) {
                return;
            }
            close(false);
        } finally {
            release();
        }
    }

    public  KafkaConsumer(Map<String, Object> configs);
    public  KafkaConsumer(Map<String, Object> configs,
        Deserializer<K> keyDeserializer,
        Deserializer<V> valueDeserializer);
    public  KafkaConsumer(Properties properties);
    public  KafkaConsumer(Properties properties,
        Deserializer<K> keyDeserializer,
        Deserializer<V> valueDeserializer);
    @SuppressWarnings("unchecked") private  KafkaConsumer(ConsumerConfig config,
        Deserializer<K> keyDeserializer,
        Deserializer<V> valueDeserializer);
      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);

}