|
@@ -122,13 +122,11 @@ static void kfk_stats_topic_free(kfk_stats_t *st_topic);
|
|
/*@}*/
|
|
/*@}*/
|
|
|
|
|
|
/**
|
|
/**
|
|
- * \brief Kafka logger callback (optional)
|
|
|
|
|
|
+ * \brief Kafka logger callback
|
|
*/
|
|
*/
|
|
static void kfk_logger (const rd_kafka_t *rk, int level,
|
|
static void kfk_logger (const rd_kafka_t *rk, int level,
|
|
const char *fac, const char *buf) {
|
|
const char *fac, const char *buf) {
|
|
|
|
|
|
- /* LM_DBG("log_level: %d\n", level); */
|
|
|
|
-
|
|
|
|
switch(level) {
|
|
switch(level) {
|
|
case LOG_EMERG:
|
|
case LOG_EMERG:
|
|
LM_NPRL("RDKAFKA fac: %s : %s : %s\n",
|
|
LM_NPRL("RDKAFKA fac: %s : %s : %s\n",
|