#include <kafka-internal.h>

Collaboration diagram for KafkaSourceOptions:

[legend]

Public Attributes
KafkaOptions	super

LogThreadedSourceWorkerOptions *	worker_options

MsgFormatOptions *	format_options

gboolean	store_kafka_metadata

GList *	requested_topics

KafkaSrcConsumerStrategy	strategy_hint

gint	time_reopen

gboolean	ignore_saved_bookmarks

gboolean	disable_bookmarks

KafkaSrcPersistStore	persist_store

guint	fetch_delay

guint	fetch_retry_delay

guint	fetch_limit

guint	fetch_queue_full_delay

gboolean	separated_worker_queues

Member Data Documentation

◆ disable_bookmarks

gboolean KafkaSourceOptions::disable_bookmarks

◆ fetch_delay

guint KafkaSourceOptions::fetch_delay

◆ fetch_limit

guint KafkaSourceOptions::fetch_limit

◆ fetch_queue_full_delay

guint KafkaSourceOptions::fetch_queue_full_delay

◆ fetch_retry_delay

guint KafkaSourceOptions::fetch_retry_delay

◆ format_options

MsgFormatOptions* KafkaSourceOptions::format_options

◆ ignore_saved_bookmarks

gboolean KafkaSourceOptions::ignore_saved_bookmarks

◆ persist_store

KafkaSrcPersistStore KafkaSourceOptions::persist_store

◆ requested_topics

GList* KafkaSourceOptions::requested_topics

◆ separated_worker_queues

gboolean KafkaSourceOptions::separated_worker_queues

◆ store_kafka_metadata

gboolean KafkaSourceOptions::store_kafka_metadata

◆ strategy_hint

KafkaSrcConsumerStrategy KafkaSourceOptions::strategy_hint

◆ super

KafkaOptions KafkaSourceOptions::super

◆ time_reopen

gint KafkaSourceOptions::time_reopen

◆ worker_options

LogThreadedSourceWorkerOptions* KafkaSourceOptions::worker_options

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

modules/kafka/kafka-internal.h

Public Attributes