Commit 35a37996 authored by Christopher Reis's avatar Christopher Reis

Added Libraries to make file

parent cc364bd8
...@@ -26,7 +26,7 @@ CXXFLAGS += $(LOCAL_DEFS) $(LOCAL_INCS) ...@@ -26,7 +26,7 @@ CXXFLAGS += $(LOCAL_DEFS) $(LOCAL_INCS)
LIBDIRS = LIBDIRS =
LIBS = LIBS = -lrdkafka -lz -lpthread -lrt
# #
SRCDIR = src SRCDIR = src
......
...@@ -46,18 +46,18 @@ using namespace std; ...@@ -46,18 +46,18 @@ using namespace std;
* Called once for each message. * Called once for each message.
* See rdkafka.h for more information. * See rdkafka.h for more information.
*/ */
static void msg_delivered (rd_kafka_t *rk, // static void msg_delivered (rd_kafka_t *rk,
void *payload, size_t len, // void *payload, size_t len,
int error_code, // int error_code,
void *opaque, void *msg_opaque) { // void *opaque, void *msg_opaque) {
//
if (error_code) // if (error_code)
fprintf(stderr, "%% Message delivery failed: %s\n", // fprintf(stderr, "%% Message delivery failed: %s\n",
rd_kafka_err2str(error_code)); // rd_kafka_err2str(error_code));
else if (!quiet) // else if (!quiet)
fprintf(stderr, "%% Message delivered (%zd bytes): %.*s\n", len, // fprintf(stderr, "%% Message delivered (%zd bytes): %.*s\n", len,
(int)len, (const char *)payload); // (int)len, (const char *)payload);
} // }
KafkaConnection::KafkaConnection(const Config& config) KafkaConnection::KafkaConnection(const Config& config)
: :
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment