summaryrefslogtreecommitdiff
path: root/src/mocking.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/mocking.c')
-rw-r--r--src/mocking.c13
1 files changed, 1 insertions, 12 deletions
diff --git a/src/mocking.c b/src/mocking.c
index c3b232c..d405489 100644
--- a/src/mocking.c
+++ b/src/mocking.c
@@ -2,17 +2,7 @@
#include "common.h"
#include <mpack.h>
-rd_kafka_t * __wrap_kafka_handle_create(const char * brokerlist, const char * sasl_username, const char * sasl_passwd)
-{
- return NULL;
-}
-
-rd_kafka_topic_t * __wrap_kafka_topic_new(rd_kafka_t * rk, const char * topic, rd_kafka_topic_conf_t * conf)
-{
- return NULL;
-}
-
-int __wrap_kafka_produce(rd_kafka_topic_t * rkt, void * payload, size_t len)
+int kafka_dump_to_log(rd_kafka_topic_t * rkt, const void * payload, size_t len)
{
struct measurements
{
@@ -104,6 +94,5 @@ int __wrap_kafka_produce(rd_kafka_topic_t * rkt, void * payload, size_t len)
dzlog_debug("comments %.*s", packet.record[i].comments_len, packet.record[i].comments);
}
- free(payload);
return 0;
} \ No newline at end of file