Closed zhangyan1298 closed 3 years ago
Common: struct { FlushInterval int; BufferSize int; MinBufferSize int; LogLevel string }{ FlushInterval: 5, BufferSize: 90000, MinBufferSize: 0, LogLevel: "debug", }, } 2020/06/18 11:08:49 [I] Prepare sql=> INSERT INTO default.daily (log,stream,master_url) VALUES (?,?,?) 2020/06/18 11:08:49 Initial [clickhouse_sinker] complete 2020/06/18 11:08:49 [I] start to dial kafka test0:9092 2020/06/18 11:08:49 [I] Run http server http://0.0.0.0:2112 2020/06/18 11:08:49 [I] TaskService daily_request TaskService has started 2020/06/18 11:08:54 [I] daily_request: tick 2020/06/18 11:08:59 [I] daily_request: tick 2020/06/18 11:09:04 [I] daily_request: tick 2020/06/18 11:09:09 [I] daily_request: tick 2020/06/18 11:09:14 [I] daily_request: tick 2020/06/18 11:09:19 [I] daily_request: tick 2020/06/18 11:09:24 [I] daily_request: tick 2020/06/18 11:09:29 [I] daily_request: tick 2020/06/18 11:09:34 [I] daily_request: tick 2020/06/18 11:09:39 [I] daily_request: tick 2020/06/18 11:09:44 [I] daily_request: tick 2020/06/18 11:09:49 [I] daily_request: tick
应该是kafka 没数据
Common: struct { FlushInterval int; BufferSize int; MinBufferSize int; LogLevel string }{ FlushInterval: 5, BufferSize: 90000, MinBufferSize: 0, LogLevel: "debug", }, } 2020/06/18 11:08:49 [I] Prepare sql=> INSERT INTO default.daily (log,stream,master_url) VALUES (?,?,?) 2020/06/18 11:08:49 Initial [clickhouse_sinker] complete 2020/06/18 11:08:49 [I] start to dial kafka test0:9092 2020/06/18 11:08:49 [I] Run http server http://0.0.0.0:2112 2020/06/18 11:08:49 [I] TaskService daily_request TaskService has started 2020/06/18 11:08:54 [I] daily_request: tick 2020/06/18 11:08:59 [I] daily_request: tick 2020/06/18 11:09:04 [I] daily_request: tick 2020/06/18 11:09:09 [I] daily_request: tick 2020/06/18 11:09:14 [I] daily_request: tick 2020/06/18 11:09:19 [I] daily_request: tick 2020/06/18 11:09:24 [I] daily_request: tick 2020/06/18 11:09:29 [I] daily_request: tick 2020/06/18 11:09:34 [I] daily_request: tick 2020/06/18 11:09:39 [I] daily_request: tick 2020/06/18 11:09:44 [I] daily_request: tick 2020/06/18 11:09:49 [I] daily_request: tick