#include <kafka-internal.h>

Public Attributes | |
| LogThreadedDestDriver | super |
| KafkaDestinationOptions | options |
| KafkaOpaque | opaque |
| rd_kafka_topic_t * | topic |
| rd_kafka_t * | kafka |
| GHashTable * | topics |
| GMutex | topics_lock |
| gboolean | transaction_inited |
| rd_kafka_t* KafkaDestDriver::kafka |
| KafkaOpaque KafkaDestDriver::opaque |
| KafkaDestinationOptions KafkaDestDriver::options |
| LogThreadedDestDriver KafkaDestDriver::super |
| rd_kafka_topic_t* KafkaDestDriver::topic |
| GHashTable* KafkaDestDriver::topics |
| GMutex KafkaDestDriver::topics_lock |
| gboolean KafkaDestDriver::transaction_inited |