class KafkaProducer implements Producer<K, V> {

    public void initTransactions() {
        throwIfNoTransactionManager();
        throwIfProducerClosed();
        TransactionalRequestResult result = transactionManager.initializeTransactions();
        sender.wakeup();
        result.await(maxBlockTimeMs, TimeUnit.MILLISECONDS);
    }

    public  KafkaProducer(final Map<String, Object> configs);
    public  KafkaProducer(Map<String, Object> configs, Serializer<K> keySerializer, Serializer<V> valueSerializer);
    public  KafkaProducer(Properties properties);
    public  KafkaProducer(Properties properties, Serializer<K> keySerializer, Serializer<V> valueSerializer);
    @SuppressWarnings("unchecked")  KafkaProducer(Map<String, Object> configs,
                  Serializer<K> keySerializer,
                  Serializer<V> valueSerializer,
                  ProducerMetadata metadata,
                  KafkaClient kafkaClient,
                  ProducerInterceptors<K, V> interceptors,
                  Time time);

}