Skip to content

G
gmsec_kafka
Commit f31a742b authored by Christopher Reis's avatar Christopher Reis
Browse files
Options

Added Message Cleanup placeholder

parent d1604c46
Show whitespace changes
Inline Side-by-side
Showing with 5 additions and 0 deletions
src/KafkaConnection.cpp
View file @ f31a742b
...@@ -60,6 +60,11 @@ static void sigterm (int sig) { ...@@ -60,6 +60,11 @@ static void sigterm (int sig) {
run = false; run = false;
} }
const char msg_clean(){
//TODO clean messages to prevent program crashes
return std::string("Test");
}
void msg_consume(RdKafka::Message* message, void* opaque) { void msg_consume(RdKafka::Message* message, void* opaque) {
switch (message->err()) { switch (message->err()) {
case RdKafka::ERR__TIMED_OUT: case RdKafka::ERR__TIMED_OUT:
......
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