diff options
| author | 童宗振 <[email protected]> | 2024-07-10 07:08:27 +0000 |
|---|---|---|
| committer | 童宗振 <[email protected]> | 2024-07-10 07:08:27 +0000 |
| commit | 9c989c18759903f09b155d86311fdecc36b15d42 (patch) | |
| tree | 87d07e43a24d6ec75d88c82c28ff71bc72e605a2 /include | |
| parent | e2200bb6c2cd93554b06d0193e4f64cee03376d9 (diff) | |
(TSG-21729)kafka send egress_action filed
Diffstat (limited to 'include')
| -rw-r--r-- | include/kafka.h | 4 | ||||
| -rw-r--r-- | include/mocking.h | 5 |
2 files changed, 3 insertions, 6 deletions
diff --git a/include/kafka.h b/include/kafka.h index 5e61e3a..b8f376f 100644 --- a/include/kafka.h +++ b/include/kafka.h @@ -1,7 +1,9 @@ #pragma once +#include "logger.h" #include <librdkafka/rdkafka.h> rd_kafka_t * kafka_handle_create(const char * brokerlist, const char * sasl_username, const char * sasl_passwd, uint32_t kafka_queue_size); rd_kafka_topic_t * kafka_topic_new(rd_kafka_t * rk, const char * topic, rd_kafka_topic_conf_t * conf); -int kafka_produce(rd_kafka_topic_t * rkt, void * payload, size_t len);
\ No newline at end of file +int kafka_produce(rd_kafka_topic_t * rkt, void * payload, size_t len); +int kafka_dump_to_log(zlog_category_t * logger, const void * payload, size_t len);
\ No newline at end of file diff --git a/include/mocking.h b/include/mocking.h deleted file mode 100644 index ed8400a..0000000 --- a/include/mocking.h +++ /dev/null @@ -1,5 +0,0 @@ -#pragma once -#include <librdkafka/rdkafka.h> -#include <zlog.h> - -int kafka_dump_to_log(zlog_category_t * logger, const void * payload, size_t len);
\ No newline at end of file |