kafka-source-worker.c File Reference

#include "kafka-source-worker.h"
#include "kafka-source-persist.h"
#include "kafka-internal.h"
#include "kafka-topic-parts.h"
#include "scratch-buffers.h"

Include dependency graph for kafka-source-worker.c:

Functions
gboolean	_has_wildcard_partition (GList *requested_topics)
const gchar *	kafka_src_worker_get_name (LogThreadedSourceWorker *worker)
LogThreadedSourceWorker *	kafka_src_worker_new (LogThreadedSourceDriver *owner, gint worker_index)

Function Documentation

_has_wildcard_partition()

gboolean _has_wildcard_partition

(

GList *

requested_topics

)

kafka_src_worker_get_name()

const gchar* kafka_src_worker_get_name ( LogThreadedSourceWorker *  worker )

inline

kafka_src_worker_new()

LogThreadedSourceWorker* kafka_src_worker_new	(	LogThreadedSourceDriver *	owner,
		gint	worker_index
	)