diff --git a/src/write_kafka.c b/src/write_kafka.c
index 75da6aaafefdc6d2bacb3de0c1fae5bdc0eb0ef0..4b42231064f0beb254b598f2d797db94e0d5370c 100644 (file)
--- a/src/write_kafka.c
+++ b/src/write_kafka.c
switch (ctx->format) {
case KAFKA_FORMAT_COMMAND:
- status = create_putval(buffer, sizeof(buffer), ds, vl);
+ status = cmd_create_putval(buffer, sizeof(buffer), ds, vl);
if (status != 0) {
- ERROR("write_kafka plugin: create_putval failed with status %i.",
+ ERROR("write_kafka plugin: cmd_create_putval failed with status %i.",
status);
return status;
}