syslog-ng source
KafkaDestDriver Struct Reference

#include <kafka-internal.h>

Collaboration diagram for KafkaDestDriver:

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
 

Member Data Documentation

◆ kafka

rd_kafka_t* KafkaDestDriver::kafka

◆ opaque

KafkaOpaque KafkaDestDriver::opaque

◆ options

KafkaDestinationOptions KafkaDestDriver::options

◆ super

LogThreadedDestDriver KafkaDestDriver::super

◆ topic

rd_kafka_topic_t* KafkaDestDriver::topic

◆ topics

GHashTable* KafkaDestDriver::topics

◆ topics_lock

GMutex KafkaDestDriver::topics_lock

◆ transaction_inited

gboolean KafkaDestDriver::transaction_inited

The documentation for this struct was generated from the following file: