Skip to content

Commit

Permalink
kafka: delete some debug code
Browse files Browse the repository at this point in the history
  • Loading branch information
Vicente Hernando committed Oct 30, 2019
1 parent f553964 commit a58e2f8
Showing 1 changed file with 0 additions and 18 deletions.
18 changes: 0 additions & 18 deletions src/modules/kafka/kfk.c
Expand Up @@ -233,24 +233,6 @@ int kfk_init(char *brokers)
*/
rk_conf = rd_kafka_conf_new();

/* Log level range 0-7 7 == LOG_DEBUG */
/* char *rk_log_level = "4"; */
/* if (rd_kafka_conf_set(rk_conf, "log_level", rk_log_level, */
/* errstr, sizeof(errstr)) != RD_KAFKA_CONF_OK) { */
/* LM_ERR("Cannot set loglevel (%s): %s\n", rk_log_level, errstr); */
/* return -1; */
/* } */

/* char *debug_option = "all"; */
/* if (rd_kafka_conf_set(rk_conf, "debug", debug_option, */
/* errstr, sizeof(errstr)) != */
/* RD_KAFKA_CONF_OK) { */
/* LM_ERR("Debug configuration failed: " */
/* "%s: %s\n", */
/* errstr, debug_option); */
/* return -1; */
/* } */

/* Set logger */
rd_kafka_conf_set_log_cb(rk_conf, kfk_logger);

Expand Down

0 comments on commit a58e2f8

Please sign in to comment.