shorten sleep time;Increase the kafka queue size, which is expected to not exceed 800M memory

2 files changed, 2 insertions, 2 deletions

diff --git a/src/kafka.c b/src/kafka.c
index d99825f..2a857f9 100644
--- a/src/kafka.c
+++ b/src/kafka.c
@@ -11,7 +11,7 @@ rd_kafka_t * kafka_handle_create(const char * brokerlist, const char * sasl_user
 
     rconf = rd_kafka_conf_new();
 
-    ret = rd_kafka_conf_set(rconf, "queue.buffering.max.messages", "1000", kafka_errstr, sizeof(kafka_errstr));
+    ret = rd_kafka_conf_set(rconf, "queue.buffering.max.messages", "100000", kafka_errstr, sizeof(kafka_errstr));
     if (ret != RD_KAFKA_CONF_OK)
     {
         dzlog_error("Error to set kafka \"queue.buffering.max.messages\", %s.", kafka_errstr);
diff --git a/src/trace_output.c b/src/trace_output.c
index fff3072..83083ab 100644
--- a/src/trace_output.c
+++ b/src/trace_output.c
@@ -136,7 +136,7 @@ void * dp_trace_process_thread(void * arg)
             if (no_pkt_recv_cnt == nr_qids)
             {
                 no_pkt_recv_cnt = 0;
-                sleep(1);
+                usleep(30);
             }
             continue;
         }