Home
last modified time | relevance | path

Searched refs:fallback_topic_name (Results 1 – 3 of 3) sorted by relevance

/dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/kafka/
H A Dkafka-dest-driver.c52 g_free(self->fallback_topic_name); in kafka_dd_set_fallback_topic()
53 self->fallback_topic_name = g_strdup(fallback_topic); in kafka_dd_set_fallback_topic()
297 evt_tag_str("fallback_topic", self->fallback_topic_name), in _kafka_delivery_report_cb()
307 evt_tag_str("fallback_topic", self->fallback_topic_name), in _kafka_delivery_report_cb()
436 evt_tag_str("fallback_topic", self->fallback_topic_name), in _flush_inflight_messages()
447 evt_tag_str("fallback_topic", self->fallback_topic_name), in _flush_inflight_messages()
481 if (!self->fallback_topic_name) in _init_template_topic_name()
494 evt_tag_str("fallback_topic", self->fallback_topic_name), in _init_template_topic_name()
633 evt_tag_str("fallback_topic", self->fallback_topic_name), in kafka_dd_init()
685 if (self->fallback_topic_name) in kafka_dd_free()
[all …]
H A Dkafka-dest-driver.h45 gchar *fallback_topic_name; member
H A Dkafka-dest-worker.c70 return owner->fallback_topic_name; in kafka_dest_worker_resolve_template_topic_name()
277 evt_tag_str("fallback_topic", owner->fallback_topic_name), in _drain_responses()