2019-11-12T20:39:29.280+0800 INFO kafka/log.go:53 client/brokers registered new broker #26 at xx.x.xx..26:9092
2019-11-12T20:39:29.280+0800 INFO kafka/log.go:53 client/brokers registered new broker #27 at xx.x.xx.27:9092
2019-11-12T20:39:29.280+0800 INFO kafka/log.go:53 client/brokers registered new broker #28 at xx.xx.xx.28:9092
2019-11-12T20:39:29.280+0800 INFO kafka/log.go:53 kafka message: Successfully initialized new client
2019-11-12T20:39:29.280+0800 INFO pipeline/output.go:105 Connection to kafka(xxxxxxxxxxxx) established
2019-11-12T20:39:29.652+0800 INFO kafka/log.go:53 producer/broker/28 starting up
2019-11-12T20:39:29.652+0800 INFO kafka/log.go:53 producer/broker/28 state change to [open] on app_log/12
2019-11-12T20:39:29.655+0800 INFO kafka/log.go:53 Connected to broker at xxxx.xx.xx.xx:9092 (registered as #28)
2019-11-12T20:39:29.963+0800 INFO kafka/log.go:53 producer/broker/26 starting up
2019-11-12T20:39:29.963+0800 INFO kafka/log.go:53 producer/broker/26 state change to [open] on app_log/70
2019-11-12T20:39:29.974+0800 INFO kafka/log.go:53 Connected to broker at xxx.xx.x.xx:9092 (registered as #26)
2019-11-12T20:39:30.322+0800 INFO kafka/log.go:53 producer/broker/28 state change to [open] on app_log/0
2019-11-12T20:39:30.326+0800 INFO kafka/log.go:53 producer/broker/28 state change to [open] on app_log/27
2019-11-12T20:39:30.522+0800 INFO kafka/log.go:53 producer/broker/28 state change to [open] on app_log/96
2019-11-12T20:39:30.624+0800 INFO kafka/log.go:53 producer/broker/28 state change to [open] on app_log/57
2019-11-12T20:39:30.729+0800 INFO kafka/log.go:53 producer/broker/26 state change to [open] on app_log/94
2019-11-12T20:39:30.877+0800 INFO kafka/log.go:53 producer/broker/27 starting up
2019-11-12T20:39:30.877+0800 INFO kafka/log.go:53 producer/broker/27 state change to [open] on app_log/5
2019-11-12T20:39:30.886+0800 INFO kafka/log.go:53 Connected to broker at xx.xx.xxx.x:9092 (registered as #27)
2019-11-12T20:39:30.994+0800 INFO kafka/log.go:53 producer/broker/27 state change to [open] on app_log/86
2019-11-12T20:39:31.115+0800 INFO kafka/log.go:53 producer/broker/28 state change to [open] on app_log/9
2019-11-12T20:39:29.280+0800 INFO kafka/log.go:53 client/brokers registered new broker #27 at xx.x.xx.27:9092
2019-11-12T20:39:29.280+0800 INFO kafka/log.go:53 client/brokers registered new broker #28 at xx.xx.xx.28:9092
2019-11-12T20:39:29.280+0800 INFO kafka/log.go:53 kafka message: Successfully initialized new client
2019-11-12T20:39:29.280+0800 INFO pipeline/output.go:105 Connection to kafka(xxxxxxxxxxxx) established
2019-11-12T20:39:29.652+0800 INFO kafka/log.go:53 producer/broker/28 starting up
2019-11-12T20:39:29.652+0800 INFO kafka/log.go:53 producer/broker/28 state change to [open] on app_log/12
2019-11-12T20:39:29.655+0800 INFO kafka/log.go:53 Connected to broker at xxxx.xx.xx.xx:9092 (registered as #28)
2019-11-12T20:39:29.963+0800 INFO kafka/log.go:53 producer/broker/26 starting up
2019-11-12T20:39:29.963+0800 INFO kafka/log.go:53 producer/broker/26 state change to [open] on app_log/70
2019-11-12T20:39:29.974+0800 INFO kafka/log.go:53 Connected to broker at xxx.xx.x.xx:9092 (registered as #26)
2019-11-12T20:39:30.322+0800 INFO kafka/log.go:53 producer/broker/28 state change to [open] on app_log/0
2019-11-12T20:39:30.326+0800 INFO kafka/log.go:53 producer/broker/28 state change to [open] on app_log/27
2019-11-12T20:39:30.522+0800 INFO kafka/log.go:53 producer/broker/28 state change to [open] on app_log/96
2019-11-12T20:39:30.624+0800 INFO kafka/log.go:53 producer/broker/28 state change to [open] on app_log/57
2019-11-12T20:39:30.729+0800 INFO kafka/log.go:53 producer/broker/26 state change to [open] on app_log/94
2019-11-12T20:39:30.877+0800 INFO kafka/log.go:53 producer/broker/27 starting up
2019-11-12T20:39:30.877+0800 INFO kafka/log.go:53 producer/broker/27 state change to [open] on app_log/5
2019-11-12T20:39:30.886+0800 INFO kafka/log.go:53 Connected to broker at xx.xx.xxx.x:9092 (registered as #27)
2019-11-12T20:39:30.994+0800 INFO kafka/log.go:53 producer/broker/27 state change to [open] on app_log/86
2019-11-12T20:39:31.115+0800 INFO kafka/log.go:53 producer/broker/28 state change to [open] on app_log/9
2 个回复
xijun - 努力吧,骚年
赞同来自:
zqc0512 - andy zhou
赞同来自:
还有就是要看这个支持的kafka版本,有些高版本是不支持低版本的kafka的。