[sarama] 2018/12/29 11:15:43.534296 client.go:110: Initializing new client
[sarama] 2018/12/29 11:15:43.534312 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:15:43.534370 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:15:43.534388 client.go:601: client/metadata fetching metadata for all topics from broker kafka3external:9095
[sarama] 2018/12/29 11:15:43.535623 broker.go:146: Connected to broker at kafka3external:9095 (unregistered)
[sarama] 2018/12/29 11:15:43.542377 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:15:43.542400 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:15:43.542408 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:15:43.542414 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:15:43.542440 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:15:43.542680 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:15:44.245362 client.go:110: Initializing new client
[sarama] 2018/12/29 11:15:44.245374 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:15:44.245415 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:15:44.245450 client.go:601: client/metadata fetching metadata for all topics from broker kafka3external:9095
[sarama] 2018/12/29 11:15:44.247285 broker.go:146: Connected to broker at kafka3external:9095 (unregistered)
[sarama] 2018/12/29 11:15:44.248340 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:15:44.248363 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:15:44.248370 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:15:44.248376 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:15:44.248392 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:15:44.248598 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:15:45.010797 client.go:110: Initializing new client
[sarama] 2018/12/29 11:15:45.010827 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:15:45.010882 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:15:45.010917 client.go:601: client/metadata fetching metadata for all topics from broker kafka3external:9095
[sarama] 2018/12/29 11:15:45.012506 broker.go:146: Connected to broker at kafka3external:9095 (unregistered)
[sarama] 2018/12/29 11:15:45.013917 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:15:45.013975 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:15:45.013999 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:15:45.014017 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:15:45.014062 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:15:45.014339 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:15:46.072519 client.go:110: Initializing new client
[sarama] 2018/12/29 11:15:46.072535 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:15:46.072579 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:15:46.072595 client.go:601: client/metadata fetching metadata for all topics from broker kafka0external:9092
[sarama] 2018/12/29 11:15:46.074175 broker.go:146: Connected to broker at kafka0external:9092 (unregistered)
[sarama] 2018/12/29 11:15:46.075161 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:15:46.075177 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:15:46.075183 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:15:46.075189 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:15:46.075227 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:15:46.075434 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:15:47.398426 client.go:110: Initializing new client
[sarama] 2018/12/29 11:15:47.398439 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:15:47.398664 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:15:47.398709 client.go:601: client/metadata fetching metadata for all topics from broker kafka0external:9092
[sarama] 2018/12/29 11:15:47.400010 broker.go:146: Connected to broker at kafka0external:9092 (unregistered)
[sarama] 2018/12/29 11:15:47.406078 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:15:47.406228 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:15:47.406278 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:15:47.406302 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:15:47.406381 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:15:47.406872 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:15:47.407062 async_producer.go:584: producer/broker/2 starting up
[sarama] 2018/12/29 11:15:47.407087 async_producer.go:596: producer/broker/2 state change to [open] on testchainid/0
[sarama] 2018/12/29 11:15:49.520973 client.go:110: Initializing new client
[sarama] 2018/12/29 11:15:49.520987 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:15:49.521034 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:15:49.521062 client.go:601: client/metadata fetching metadata for all topics from broker kafka2external:9094
[sarama] 2018/12/29 11:15:49.522797 broker.go:146: Connected to broker at kafka2external:9094 (unregistered)
[sarama] 2018/12/29 11:15:49.524338 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:15:49.524360 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:15:49.524367 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:15:49.524373 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:15:49.524387 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:15:49.525063 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:15:49.525643 async_producer.go:584: producer/broker/2 starting up
[sarama] 2018/12/29 11:15:49.525753 async_producer.go:596: producer/broker/2 state change to [open] on testchainid/0
[sarama] 2018/12/29 11:15:49.526118 broker.go:144: Connected to broker at kafka2external:9094 (registered as #2)
[sarama] 2018/12/29 11:15:49.530997 client.go:110: Initializing new client
[sarama] 2018/12/29 11:15:49.531005 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:15:49.531247 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:15:49.531286 client.go:601: client/metadata fetching metadata for all topics from broker kafka1external:9093
[sarama] 2018/12/29 11:15:53.280358 client.go:110: Initializing new client
[sarama] 2018/12/29 11:15:53.280519 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:15:53.280648 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:15:53.280754 client.go:601: client/metadata fetching metadata for all topics from broker kafka3external:9095
[sarama] 2018/12/29 11:15:53.282699 broker.go:146: Connected to broker at kafka3external:9095 (unregistered)
[sarama] 2018/12/29 11:15:53.284516 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:15:53.284654 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:15:53.284700 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:15:53.284722 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:15:53.284782 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:15:53.285422 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:16:00.240950 client.go:110: Initializing new client
[sarama] 2018/12/29 11:16:00.240971 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:16:00.241025 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:16:00.241049 client.go:601: client/metadata fetching metadata for all topics from broker kafka0external:9092
[sarama] 2018/12/29 11:16:00.242348 broker.go:146: Connected to broker at kafka0external:9092 (unregistered)
[sarama] 2018/12/29 11:16:00.244516 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:16:00.244594 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:16:00.244618 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:16:00.244637 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:16:00.244691 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:16:00.245123 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:16:13.599829 client.go:110: Initializing new client
[sarama] 2018/12/29 11:16:13.599841 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:16:13.599901 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:16:13.599938 client.go:601: client/metadata fetching metadata for all topics from broker kafka3external:9095
[sarama] 2018/12/29 11:16:13.601797 broker.go:146: Connected to broker at kafka3external:9095 (unregistered)
[sarama] 2018/12/29 11:16:13.606519 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:16:13.606544 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:16:13.606551 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:16:13.606558 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:16:13.606634 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:16:13.607267 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:16:39.742775 client.go:110: Initializing new client
[sarama] 2018/12/29 11:16:39.742793 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:16:39.742843 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:16:39.742873 client.go:601: client/metadata fetching metadata for all topics from broker kafka0external:9092
[sarama] 2018/12/29 11:16:39.744322 broker.go:146: Connected to broker at kafka0external:9092 (unregistered)
[sarama] 2018/12/29 11:16:39.745922 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:16:39.746046 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:16:39.746117 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:16:39.746179 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:16:39.746256 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:16:39.746756 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:17:31.456694 client.go:110: Initializing new client
[sarama] 2018/12/29 11:17:31.456718 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:17:31.456788 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:17:31.456813 client.go:601: client/metadata fetching metadata for all topics from broker kafka1external:9093
[sarama] 2018/12/29 11:17:31.458624 broker.go:146: Connected to broker at kafka1external:9093 (unregistered)
[sarama] 2018/12/29 11:17:31.461199 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:17:31.461211 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:17:31.461218 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:17:31.461223 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:17:31.461236 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:17:31.461425 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:18:31.955108 client.go:110: Initializing new client
[sarama] 2018/12/29 11:18:31.955152 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:18:31.955201 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:18:31.955267 client.go:601: client/metadata fetching metadata for all topics from broker kafka3external:9095
[sarama] 2018/12/29 11:18:31.956529 broker.go:146: Connected to broker at kafka3external:9095 (unregistered)
[sarama] 2018/12/29 11:18:31.959172 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:18:31.959195 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:18:31.959202 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:18:31.959208 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:18:31.959262 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:18:31.959593 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:19:32.469550 client.go:110: Initializing new client
[sarama] 2018/12/29 11:19:32.469567 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:19:32.469614 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:19:32.469640 client.go:601: client/metadata fetching metadata for all topics from broker kafka0external:9092
[sarama] 2018/12/29 11:19:32.471331 broker.go:146: Connected to broker at kafka0external:9092 (unregistered)
[sarama] 2018/12/29 11:19:32.473736 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:19:32.473758 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:19:32.473768 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:19:32.473777 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:19:32.473800 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:19:32.474077 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:20:32.987165 client.go:110: Initializing new client
[sarama] 2018/12/29 11:20:32.987177 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:20:32.987264 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:20:32.987294 client.go:601: client/metadata fetching metadata for all topics from broker kafka3external:9095
[sarama] 2018/12/29 11:20:32.988782 broker.go:146: Connected to broker at kafka3external:9095 (unregistered)
[sarama] 2018/12/29 11:20:32.995440 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:20:32.995460 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:20:32.995467 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:20:32.995473 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:20:32.995506 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:20:32.995687 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:21:33.524497 client.go:110: Initializing new client
[sarama] 2018/12/29 11:21:33.524549 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:21:33.524598 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:21:33.524676 client.go:601: client/metadata fetching metadata for all topics from broker kafka0external:9092
[sarama] 2018/12/29 11:21:33.526574 broker.go:146: Connected to broker at kafka0external:9092 (unregistered)
[sarama] 2018/12/29 11:21:33.529579 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:21:33.529600 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:21:33.529607 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:21:33.529613 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:21:33.529658 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:21:33.530006 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:21:33.530056 async_producer.go:584: producer/broker/2 starting up
[sarama] 2018/12/29 11:21:33.530064 async_producer.go:596: producer/broker/2 state change to [open] on testchainid/0
[sarama] 2018/12/29 11:22:34.043903 client.go:110: Initializing new client
[sarama] 2018/12/29 11:22:34.043922 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:22:34.043984 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:22:34.044011 client.go:601: client/metadata fetching metadata for all topics from broker kafka0external:9092
[sarama] 2018/12/29 11:22:34.045342 broker.go:146: Connected to broker at kafka0external:9092 (unregistered)
[sarama] 2018/12/29 11:22:34.046722 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:22:34.046745 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:22:34.046752 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:22:34.046758 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:22:34.046772 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:22:34.046974 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:23:34.570753 client.go:110: Initializing new client
[sarama] 2018/12/29 11:23:34.570766 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:23:34.570829 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:23:34.570863 client.go:601: client/metadata fetching metadata for all topics from broker kafka1external:9093
[sarama] 2018/12/29 11:23:34.572894 broker.go:146: Connected to broker at kafka1external:9093 (unregistered)
[sarama] 2018/12/29 11:23:34.576687 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:23:34.576710 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:23:34.576718 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:23:34.576724 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:23:34.576792 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:23:34.577207 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:24:35.130231 client.go:110: Initializing new client
[sarama] 2018/12/29 11:24:35.130245 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:24:35.130302 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:24:35.130333 client.go:601: client/metadata fetching metadata for all topics from broker kafka0external:9092
[sarama] 2018/12/29 11:24:35.131673 broker.go:146: Connected to broker at kafka0external:9092 (unregistered)
[sarama] 2018/12/29 11:24:35.133892 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:24:35.133931 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:24:35.133939 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:24:35.133945 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:24:35.133959 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:24:35.134155 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:25:35.631213 client.go:110: Initializing new client
[sarama] 2018/12/29 11:25:35.631224 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:25:35.631266 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:25:35.631298 client.go:601: client/metadata fetching metadata for all topics from broker kafka2external:9094
[sarama] 2018/12/29 11:25:35.632795 broker.go:146: Connected to broker at kafka2external:9094 (unregistered)
[sarama] 2018/12/29 11:25:35.634543 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:25:35.634558 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:25:35.634564 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:25:35.634570 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:25:35.634585 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:25:35.634770 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:26:36.146622 client.go:110: Initializing new client
[sarama] 2018/12/29 11:26:36.146702 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:26:36.146748 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:26:36.146777 client.go:601: client/metadata fetching metadata for all topics from broker kafka2external:9094
[sarama] 2018/12/29 11:26:36.148398 broker.go:146: Connected to broker at kafka2external:9094 (unregistered)
[sarama] 2018/12/29 11:26:36.149656 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:26:36.149671 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:26:36.149677 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:26:36.149683 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:26:36.149699 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:26:36.149889 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:27:36.688557 client.go:110: Initializing new client
[sarama] 2018/12/29 11:27:36.688572 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:27:36.688626 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:27:36.688658 client.go:601: client/metadata fetching metadata for all topics from broker kafka2external:9094
[sarama] 2018/12/29 11:27:36.690652 broker.go:146: Connected to broker at kafka2external:9094 (unregistered)
[sarama] 2018/12/29 11:27:36.692056 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:27:36.692329 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:27:36.692825 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:27:36.692939 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:27:36.693025 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:27:36.693669 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:28:37.214179 client.go:110: Initializing new client
[sarama] 2018/12/29 11:28:37.214193 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:28:37.214243 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:28:37.214272 client.go:601: client/metadata fetching metadata for all topics from broker kafka0external:9092
[sarama] 2018/12/29 11:28:37.216265 broker.go:146: Connected to broker at kafka0external:9092 (unregistered)
[sarama] 2018/12/29 11:28:37.217631 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:28:37.217667 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:28:37.217675 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:28:37.217681 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:28:37.217713 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:28:37.217967 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:29:37.742641 client.go:110: Initializing new client
[sarama] 2018/12/29 11:29:37.742653 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:29:37.742699 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:29:37.742730 client.go:601: client/metadata fetching metadata for all topics from broker kafka3external:9095
[sarama] 2018/12/29 11:29:37.745016 broker.go:146: Connected to broker at kafka3external:9095 (unregistered)
[sarama] 2018/12/29 11:29:37.746470 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:29:37.746483 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:29:37.746489 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:29:37.746495 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:29:37.746533 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:29:37.746747 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:30:38.310592 client.go:110: Initializing new client
[sarama] 2018/12/29 11:30:38.310605 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:30:38.310652 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:30:38.310680 client.go:601: client/metadata fetching metadata for all topics from broker kafka1external:9093
[sarama] 2018/12/29 11:30:38.312355 broker.go:146: Connected to broker at kafka1external:9093 (unregistered)
[sarama] 2018/12/29 11:30:38.313649 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:30:38.313660 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:30:38.313666 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:30:38.313672 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:30:38.313684 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:30:38.314015 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:31:38.846788 client.go:110: Initializing new client
[sarama] 2018/12/29 11:31:38.846852 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:31:38.846949 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:31:38.847027 client.go:601: client/metadata fetching metadata for all topics from broker kafka0external:9092
[sarama] 2018/12/29 11:31:38.848339 broker.go:146: Connected to broker at kafka0external:9092 (unregistered)
[sarama] 2018/12/29 11:31:38.850074 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:31:38.850138 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:31:38.850165 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:31:38.850205 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:31:38.850235 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:31:38.850650 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:32:39.366673 client.go:110: Initializing new client
[sarama] 2018/12/29 11:32:39.366688 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:32:39.366798 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:32:39.366835 client.go:601: client/metadata fetching metadata for all topics from broker kafka1external:9093
[sarama] 2018/12/29 11:32:39.368708 broker.go:146: Connected to broker at kafka1external:9093 (unregistered)
[sarama] 2018/12/29 11:32:39.370048 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:32:39.370119 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:32:39.370144 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:32:39.370162 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:32:39.370191 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:32:39.370747 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:33:39.943742 client.go:110: Initializing new client
[sarama] 2018/12/29 11:33:39.943757 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:33:39.943812 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:33:39.943844 client.go:601: client/metadata fetching metadata for all topics from broker kafka3external:9095
[sarama] 2018/12/29 11:33:39.945510 broker.go:146: Connected to broker at kafka3external:9095 (unregistered)
[sarama] 2018/12/29 11:33:39.946980 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:33:39.947087 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:33:39.947150 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:33:39.947208 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:33:39.947272 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:33:39.947875 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:34:40.460488 client.go:110: Initializing new client
[sarama] 2018/12/29 11:34:40.460505 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:34:40.460567 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:34:40.460596 client.go:601: client/metadata fetching metadata for all topics from broker kafka0external:9092
[sarama] 2018/12/29 11:34:40.461916 broker.go:146: Connected to broker at kafka0external:9092 (unregistered)
[sarama] 2018/12/29 11:34:40.464743 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:34:40.464778 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:34:40.464789 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:34:40.464799 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:34:40.464820 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:34:40.465094 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:35:40.972215 client.go:110: Initializing new client
[sarama] 2018/12/29 11:35:40.972227 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:35:40.972272 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:35:40.972288 client.go:601: client/metadata fetching metadata for all topics from broker kafka2external:9094
[sarama] 2018/12/29 11:35:40.975741 broker.go:146: Connected to broker at kafka2external:9094 (unregistered)
[sarama] 2018/12/29 11:35:40.976919 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:35:40.976941 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:35:40.976947 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:35:40.976953 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:35:40.976969 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:35:40.977218 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:36:41.516443 client.go:110: Initializing new client
[sarama] 2018/12/29 11:36:41.516460 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:36:41.516569 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:36:41.516609 client.go:601: client/metadata fetching metadata for all topics from broker kafka2external:9094
[sarama] 2018/12/29 11:36:41.518327 broker.go:146: Connected to broker at kafka2external:9094 (unregistered)
[sarama] 2018/12/29 11:36:41.519169 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:36:41.519182 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:36:41.519188 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:36:41.519194 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:36:41.519219 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:36:41.519425 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:36:41.519540 async_producer.go:584: producer/broker/2 starting up
[sarama] 2018/12/29 11:36:41.519556 async_producer.go:596: producer/broker/2 state change to [open] on testchainid/0
[sarama] 2018/12/29 11:37:42.028880 client.go:110: Initializing new client
[sarama] 2018/12/29 11:37:42.028893 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:37:42.028939 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:37:42.028967 client.go:601: client/metadata fetching metadata for all topics from broker kafka1external:9093
[sarama] 2018/12/29 11:37:42.030061 broker.go:146: Connected to broker at kafka1external:9093 (unregistered)
[sarama] 2018/12/29 11:37:42.032092 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:37:42.032112 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:37:42.032118 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:37:42.032124 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:37:42.032156 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:37:42.032356 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:38:42.577347 client.go:110: Initializing new client
[sarama] 2018/12/29 11:38:42.577359 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:38:42.577402 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:38:42.577432 client.go:601: client/metadata fetching metadata for all topics from broker kafka3external:9095
[sarama] 2018/12/29 11:38:42.578809 broker.go:146: Connected to broker at kafka3external:9095 (unregistered)
[sarama] 2018/12/29 11:38:42.583344 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:38:42.583415 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:38:42.583427 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:38:42.583437 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:38:42.583468 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:38:42.583752 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:39:43.108260 client.go:110: Initializing new client
[sarama] 2018/12/29 11:39:43.108273 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:39:43.108328 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:39:43.108455 client.go:601: client/metadata fetching metadata for all topics from broker kafka2external:9094
[sarama] 2018/12/29 11:39:43.110119 broker.go:146: Connected to broker at kafka2external:9094 (unregistered)
[sarama] 2018/12/29 11:39:43.111111 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:39:43.111190 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:39:43.111361 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:39:43.111470 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:39:43.111619 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:39:43.112450 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:40:43.643599 client.go:110: Initializing new client
[sarama] 2018/12/29 11:40:43.643611 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:40:43.643661 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:40:43.643690 client.go:601: client/metadata fetching metadata for all topics from broker kafka3external:9095
[sarama] 2018/12/29 11:40:43.645095 broker.go:146: Connected to broker at kafka3external:9095 (unregistered)
[sarama] 2018/12/29 11:40:43.646275 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:40:43.646292 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:40:43.646298 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:40:43.646304 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:40:43.646321 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:40:43.646516 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:41:44.155798 client.go:110: Initializing new client
[sarama] 2018/12/29 11:41:44.155812 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:41:44.155861 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:41:44.155892 client.go:601: client/metadata fetching metadata for all topics from broker kafka2external:9094
[sarama] 2018/12/29 11:41:44.157424 broker.go:146: Connected to broker at kafka2external:9094 (unregistered)
[sarama] 2018/12/29 11:41:44.160270 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:41:44.160392 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:41:44.160470 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:41:44.160495 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:41:44.160609 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:41:44.161142 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:42:44.667146 client.go:110: Initializing new client
[sarama] 2018/12/29 11:42:44.667160 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:42:44.667206 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:42:44.667282 client.go:601: client/metadata fetching metadata for all topics from broker kafka3external:9095
[sarama] 2018/12/29 11:42:44.668805 broker.go:146: Connected to broker at kafka3external:9095 (unregistered)
[sarama] 2018/12/29 11:42:44.669950 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:42:44.669962 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:42:44.669968 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:42:44.669974 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:42:44.669988 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:42:44.670284 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:43:45.173681 client.go:110: Initializing new client
[sarama] 2018/12/29 11:43:45.173701 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:43:45.173753 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:43:45.173770 client.go:601: client/metadata fetching metadata for all topics from broker kafka1external:9093
[sarama] 2018/12/29 11:43:45.175295 broker.go:146: Connected to broker at kafka1external:9093 (unregistered)
[sarama] 2018/12/29 11:43:45.179765 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:43:45.179787 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:43:45.179794 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:43:45.179800 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:43:45.179818 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:43:45.180013 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:44:45.717376 client.go:110: Initializing new client
[sarama] 2018/12/29 11:44:45.717387 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:44:45.717432 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:44:45.717462 client.go:601: client/metadata fetching metadata for all topics from broker kafka3external:9095
[sarama] 2018/12/29 11:44:45.720089 broker.go:146: Connected to broker at kafka3external:9095 (unregistered)
[sarama] 2018/12/29 11:44:45.721207 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:44:45.721230 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:44:45.721238 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:44:45.721244 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:44:45.721265 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:44:45.721542 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:45:46.243496 client.go:110: Initializing new client
[sarama] 2018/12/29 11:45:46.243509 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:45:46.243560 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:45:46.243592 client.go:601: client/metadata fetching metadata for all topics from broker kafka1external:9093
[sarama] 2018/12/29 11:45:46.244951 broker.go:146: Connected to broker at kafka1external:9093 (unregistered)
[sarama] 2018/12/29 11:45:46.247827 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:45:46.247850 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:45:46.247857 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:45:46.247864 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:45:46.247920 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:45:46.248567 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:46:46.780905 client.go:110: Initializing new client
[sarama] 2018/12/29 11:46:46.780924 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:46:46.780972 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:46:46.781003 client.go:601: client/metadata fetching metadata for all topics from broker kafka1external:9093
[sarama] 2018/12/29 11:46:46.782366 broker.go:146: Connected to broker at kafka1external:9093 (unregistered)
[sarama] 2018/12/29 11:46:46.785244 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:46:46.785336 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:46:46.785378 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:46:46.785484 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:46:46.785564 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:46:46.786188 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:46:46.786331 async_producer.go:584: producer/broker/2 starting up
[sarama] 2018/12/29 11:46:46.786353 async_producer.go:596: producer/broker/2 state change to [open] on testchainid/0
[sarama] 2018/12/29 11:46:46.787689 broker.go:144: Connected to broker at kafka2external:9094 (registered as #2)
[sarama] 2018/12/29 11:46:46.793032 client.go:110: Initializing new client
[sarama] 2018/12/29 11:46:46.793121 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:46:46.793245 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:46:46.793334 client.go:601: client/metadata fetching metadata for all topics from broker kafka1external:9093
[sarama] 2018/12/29 11:47:47.312910 client.go:110: Initializing new client
[sarama] 2018/12/29 11:47:47.312923 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:47:47.313029 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:47:47.313201 client.go:601: client/metadata fetching metadata for all topics from broker kafka2external:9094
[sarama] 2018/12/29 11:47:47.315700 broker.go:146: Connected to broker at kafka2external:9094 (unregistered)
[sarama] 2018/12/29 11:47:47.316646 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:47:47.316660 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:47:47.316667 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:47:47.316673 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:47:47.316699 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:47:47.316908 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:48:47.833042 client.go:110: Initializing new client
[sarama] 2018/12/29 11:48:47.833087 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:48:47.833137 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:48:47.833164 client.go:601: client/metadata fetching metadata for all topics from broker kafka0external:9092
[sarama] 2018/12/29 11:48:47.834983 broker.go:146: Connected to broker at kafka0external:9092 (unregistered)
[sarama] 2018/12/29 11:48:47.835893 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:48:47.835905 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:48:47.835912 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:48:47.835917 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:48:47.835930 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:48:47.836103 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:49:48.381213 client.go:110: Initializing new client
[sarama] 2018/12/29 11:49:48.381225 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:49:48.381270 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:49:48.381299 client.go:601: client/metadata fetching metadata for all topics from broker kafka2external:9094
[sarama] 2018/12/29 11:49:48.388990 broker.go:146: Connected to broker at kafka2external:9094 (unregistered)
[sarama] 2018/12/29 11:49:48.389865 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:49:48.389891 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:49:48.389898 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:49:48.389904 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:49:48.389918 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:49:48.390119 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:50:48.929522 client.go:110: Initializing new client
[sarama] 2018/12/29 11:50:48.929534 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:50:48.929586 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:50:48.929617 client.go:601: client/metadata fetching metadata for all topics from broker kafka0external:9092
[sarama] 2018/12/29 11:50:48.931150 broker.go:146: Connected to broker at kafka0external:9092 (unregistered)
[sarama] 2018/12/29 11:50:48.932192 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:50:48.932258 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:50:48.932282 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:50:48.932339 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:50:48.932498 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:50:48.933195 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:51:49.446731 client.go:110: Initializing new client
[sarama] 2018/12/29 11:51:49.446743 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:51:49.446801 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:51:49.446835 client.go:601: client/metadata fetching metadata for all topics from broker kafka3external:9095
[sarama] 2018/12/29 11:51:49.448649 broker.go:146: Connected to broker at kafka3external:9095 (unregistered)
[sarama] 2018/12/29 11:51:49.450537 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:51:49.450553 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:51:49.450560 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:51:49.450566 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:51:49.450585 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:51:49.450782 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:52:50.001574 client.go:110: Initializing new client
[sarama] 2018/12/29 11:52:50.001592 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:52:50.001646 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:52:50.001676 client.go:601: client/metadata fetching metadata for all topics from broker kafka1external:9093
[sarama] 2018/12/29 11:52:50.003660 broker.go:146: Connected to broker at kafka1external:9093 (unregistered)
[sarama] 2018/12/29 11:52:50.005927 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:52:50.005948 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:52:50.005955 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:52:50.005961 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:52:50.005974 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:52:50.006179 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:53:50.536639 client.go:110: Initializing new client
[sarama] 2018/12/29 11:53:50.536655 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:53:50.536703 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:53:50.536730 client.go:601: client/metadata fetching metadata for all topics from broker kafka0external:9092
[sarama] 2018/12/29 11:53:50.538250 broker.go:146: Connected to broker at kafka0external:9092 (unregistered)
[sarama] 2018/12/29 11:53:50.540148 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:53:50.540162 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:53:50.540168 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:53:50.540174 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:53:50.540202 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:53:50.540401 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:54:51.094244 client.go:110: Initializing new client
[sarama] 2018/12/29 11:54:51.094258 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:54:51.094309 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:54:51.094328 client.go:601: client/metadata fetching metadata for all topics from broker kafka2external:9094
[sarama] 2018/12/29 11:54:51.095707 broker.go:146: Connected to broker at kafka2external:9094 (unregistered)
[sarama] 2018/12/29 11:54:51.097217 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:54:51.097280 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:54:51.097360 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:54:51.097402 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:54:51.097527 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:54:51.098162 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:55:51.672786 client.go:110: Initializing new client
[sarama] 2018/12/29 11:55:51.672855 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:55:51.672939 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:55:51.673022 client.go:601: client/metadata fetching metadata for all topics from broker kafka2external:9094
[sarama] 2018/12/29 11:55:51.674891 broker.go:146: Connected to broker at kafka2external:9094 (unregistered)
[sarama] 2018/12/29 11:55:51.676075 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:55:51.676101 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:55:51.676109 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:55:51.676115 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:55:51.676298 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:55:51.677070 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:56:52.228869 client.go:110: Initializing new client
[sarama] 2018/12/29 11:56:52.228881 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:56:52.228937 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:56:52.228967 client.go:601: client/metadata fetching metadata for all topics from broker kafka0external:9092
[sarama] 2018/12/29 11:56:52.230721 broker.go:146: Connected to broker at kafka0external:9092 (unregistered)
[sarama] 2018/12/29 11:56:52.232938 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:56:52.233064 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:56:52.233148 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:56:52.233187 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:56:52.233218 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:56:52.233871 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:57:52.757871 client.go:110: Initializing new client
[sarama] 2018/12/29 11:57:52.757895 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:57:52.757951 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:57:52.757991 client.go:601: client/metadata fetching metadata for all topics from broker kafka2external:9094
[sarama] 2018/12/29 11:57:52.759572 broker.go:146: Connected to broker at kafka2external:9094 (unregistered)
[sarama] 2018/12/29 11:57:52.760845 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:57:52.760860 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:57:52.760866 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:57:52.760872 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:57:52.760887 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:57:52.761132 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:58:53.293497 client.go:110: Initializing new client
[sarama] 2018/12/29 11:58:53.293509 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:58:53.293554 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:58:53.293579 client.go:601: client/metadata fetching metadata for all topics from broker kafka2external:9094
[sarama] 2018/12/29 11:58:53.295872 broker.go:146: Connected to broker at kafka2external:9094 (unregistered)
[sarama] 2018/12/29 11:58:53.297935 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:58:53.298065 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:58:53.298129 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:58:53.298226 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:58:53.298361 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:58:53.299046 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:58:53.299253 async_producer.go:584: producer/broker/2 starting up
[sarama] 2018/12/29 11:58:53.299277 async_producer.go:596: producer/broker/2 state change to [open] on testchainid/0
[sarama] 2018/12/29 11:59:53.853075 client.go:110: Initializing new client
[sarama] 2018/12/29 11:59:53.853088 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:59:53.853148 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:59:53.853177 client.go:601: client/metadata fetching metadata for all topics from broker kafka2external:9094
[sarama] 2018/12/29 11:59:53.855281 broker.go:146: Connected to broker at kafka2external:9094 (unregistered)
[sarama] 2018/12/29 11:59:53.856180 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 11:59:53.856200 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 11:59:53.856207 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 11:59:53.856213 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 11:59:53.856237 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 11:59:53.856421 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:59:53.856678 async_producer.go:584: producer/broker/2 starting up
[sarama] 2018/12/29 11:59:53.856800 async_producer.go:596: producer/broker/2 state change to [open] on testchainid/0
[sarama] 2018/12/29 11:59:53.857251 broker.go:144: Connected to broker at kafka2external:9094 (registered as #2)
[sarama] 2018/12/29 11:59:53.866538 client.go:110: Initializing new client
[sarama] 2018/12/29 11:59:53.866658 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:59:53.866881 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 11:59:53.867035 client.go:601: client/metadata fetching metadata for all topics from broker kafka3external:9095
[sarama] 2018/12/29 12:00:54.398643 client.go:110: Initializing new client
[sarama] 2018/12/29 12:00:54.398655 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:00:54.398700 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:00:54.398729 client.go:601: client/metadata fetching metadata for all topics from broker kafka1external:9093
[sarama] 2018/12/29 12:00:54.401208 broker.go:146: Connected to broker at kafka1external:9093 (unregistered)
[sarama] 2018/12/29 12:00:54.403041 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 12:00:54.403053 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 12:00:54.403060 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 12:00:54.403065 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 12:00:54.403078 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 12:00:54.403261 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:01:54.948773 client.go:110: Initializing new client
[sarama] 2018/12/29 12:01:54.948788 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:01:54.948840 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:01:54.948882 client.go:601: client/metadata fetching metadata for all topics from broker kafka2external:9094
[sarama] 2018/12/29 12:01:54.950599 broker.go:146: Connected to broker at kafka2external:9094 (unregistered)
[sarama] 2018/12/29 12:01:54.951812 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 12:01:54.951828 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 12:01:54.951835 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 12:01:54.951840 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 12:01:54.951859 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 12:01:54.952055 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:02:55.485694 client.go:110: Initializing new client
[sarama] 2018/12/29 12:02:55.485706 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:02:55.485954 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:02:55.485990 client.go:601: client/metadata fetching metadata for all topics from broker kafka0external:9092
[sarama] 2018/12/29 12:02:55.487894 broker.go:146: Connected to broker at kafka0external:9092 (unregistered)
[sarama] 2018/12/29 12:02:55.488691 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 12:02:55.488702 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 12:02:55.488709 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 12:02:55.488714 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 12:02:55.488727 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 12:02:55.489060 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:03:56.046669 client.go:110: Initializing new client
[sarama] 2018/12/29 12:03:56.046683 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:03:56.046733 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:03:56.046766 client.go:601: client/metadata fetching metadata for all topics from broker kafka3external:9095
[sarama] 2018/12/29 12:03:56.048408 broker.go:146: Connected to broker at kafka3external:9095 (unregistered)
[sarama] 2018/12/29 12:03:56.049858 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 12:03:56.049884 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 12:03:56.049891 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 12:03:56.049897 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 12:03:56.049962 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 12:03:56.050573 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:04:56.577284 client.go:110: Initializing new client
[sarama] 2018/12/29 12:04:56.577301 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:04:56.577353 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:04:56.577384 client.go:601: client/metadata fetching metadata for all topics from broker kafka3external:9095
[sarama] 2018/12/29 12:04:56.578509 broker.go:146: Connected to broker at kafka3external:9095 (unregistered)
[sarama] 2018/12/29 12:04:56.580289 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 12:04:56.580312 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 12:04:56.580318 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 12:04:56.580324 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 12:04:56.580348 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 12:04:56.580575 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:05:57.106606 client.go:110: Initializing new client
[sarama] 2018/12/29 12:05:57.106665 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:05:57.106877 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:05:57.106943 client.go:601: client/metadata fetching metadata for all topics from broker kafka3external:9095
[sarama] 2018/12/29 12:05:57.108175 broker.go:146: Connected to broker at kafka3external:9095 (unregistered)
[sarama] 2018/12/29 12:05:57.109736 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 12:05:57.109795 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 12:05:57.109833 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 12:05:57.109992 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 12:05:57.110108 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 12:05:57.110809 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:06:57.595645 client.go:110: Initializing new client
[sarama] 2018/12/29 12:06:57.595662 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:06:57.595880 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:06:57.595915 client.go:601: client/metadata fetching metadata for all topics from broker kafka1external:9093
[sarama] 2018/12/29 12:06:57.597765 broker.go:146: Connected to broker at kafka1external:9093 (unregistered)
[sarama] 2018/12/29 12:06:57.603495 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 12:06:57.603514 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 12:06:57.603521 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 12:06:57.603527 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 12:06:57.603553 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 12:06:57.603777 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:07:58.124795 client.go:110: Initializing new client
[sarama] 2018/12/29 12:07:58.124814 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:07:58.124868 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:07:58.124884 client.go:601: client/metadata fetching metadata for all topics from broker kafka1external:9093
[sarama] 2018/12/29 12:07:58.129314 broker.go:146: Connected to broker at kafka1external:9093 (unregistered)
[sarama] 2018/12/29 12:07:58.130737 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 12:07:58.130803 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 12:07:58.130850 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 12:07:58.130900 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 12:07:58.130935 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 12:07:58.131443 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:08:58.670679 client.go:110: Initializing new client
[sarama] 2018/12/29 12:08:58.670697 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:08:58.670748 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:08:58.670773 client.go:601: client/metadata fetching metadata for all topics from broker kafka0external:9092
[sarama] 2018/12/29 12:08:58.672618 broker.go:146: Connected to broker at kafka0external:9092 (unregistered)
[sarama] 2018/12/29 12:08:58.673807 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 12:08:58.673935 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 12:08:58.674042 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 12:08:58.674138 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 12:08:58.674262 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 12:08:58.675009 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:09:59.204942 client.go:110: Initializing new client
[sarama] 2018/12/29 12:09:59.204960 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:09:59.205005 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:09:59.205034 client.go:601: client/metadata fetching metadata for all topics from broker kafka2external:9094
[sarama] 2018/12/29 12:09:59.206835 broker.go:146: Connected to broker at kafka2external:9094 (unregistered)
[sarama] 2018/12/29 12:09:59.208195 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 12:09:59.208374 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 12:09:59.208439 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 12:09:59.208592 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 12:09:59.208702 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 12:09:59.209698 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:10:59.728182 client.go:110: Initializing new client
[sarama] 2018/12/29 12:10:59.728195 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:10:59.728254 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:10:59.728288 client.go:601: client/metadata fetching metadata for all topics from broker kafka3external:9095
[sarama] 2018/12/29 12:10:59.729546 broker.go:146: Connected to broker at kafka3external:9095 (unregistered)
[sarama] 2018/12/29 12:10:59.731282 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 12:10:59.731297 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 12:10:59.731304 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 12:10:59.731309 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 12:10:59.731324 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 12:10:59.731651 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:12:00.282077 client.go:110: Initializing new client
[sarama] 2018/12/29 12:12:00.282091 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:12:00.282151 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:12:00.282188 client.go:601: client/metadata fetching metadata for all topics from broker kafka1external:9093
[sarama] 2018/12/29 12:12:00.283953 broker.go:146: Connected to broker at kafka1external:9093 (unregistered)
[sarama] 2018/12/29 12:12:00.285693 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 12:12:00.285716 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 12:12:00.285723 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 12:12:00.285729 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 12:12:00.285748 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 12:12:00.286192 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:13:00.819223 client.go:110: Initializing new client
[sarama] 2018/12/29 12:13:00.819241 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:13:00.819317 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:13:00.819346 client.go:601: client/metadata fetching metadata for all topics from broker kafka3external:9095
[sarama] 2018/12/29 12:13:00.820993 broker.go:146: Connected to broker at kafka3external:9095 (unregistered)
[sarama] 2018/12/29 12:13:00.822208 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 12:13:00.822229 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 12:13:00.822236 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 12:13:00.822242 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 12:13:00.822258 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 12:13:00.822633 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:14:01.341621 client.go:110: Initializing new client
[sarama] 2018/12/29 12:14:01.341641 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:14:01.341826 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:14:01.341902 client.go:601: client/metadata fetching metadata for all topics from broker kafka1external:9093
[sarama] 2018/12/29 12:14:01.343524 broker.go:146: Connected to broker at kafka1external:9093 (unregistered)
[sarama] 2018/12/29 12:14:01.346089 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 12:14:01.346152 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 12:14:01.346176 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 12:14:01.346195 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 12:14:01.346262 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 12:14:01.346675 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:14:01.346997 async_producer.go:584: producer/broker/2 starting up
[sarama] 2018/12/29 12:14:01.347053 async_producer.go:596: producer/broker/2 state change to [open] on testchainid/0
[sarama] 2018/12/29 12:14:01.347762 broker.go:144: Connected to broker at kafka2external:9094 (registered as #2)
[sarama] 2018/12/29 12:14:01.357612 client.go:110: Initializing new client
[sarama] 2018/12/29 12:14:01.357621 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:14:01.357661 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:14:01.357689 client.go:601: client/metadata fetching metadata for all topics from broker kafka1external:9093
[sarama] 2018/12/29 12:15:01.846665 client.go:110: Initializing new client
[sarama] 2018/12/29 12:15:01.846677 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:15:01.846767 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:15:01.846799 client.go:601: client/metadata fetching metadata for all topics from broker kafka1external:9093
[sarama] 2018/12/29 12:15:01.848472 broker.go:146: Connected to broker at kafka1external:9093 (unregistered)
[sarama] 2018/12/29 12:15:01.851829 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 12:15:01.851850 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 12:15:01.851857 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 12:15:01.851863 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 12:15:01.851878 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 12:15:01.852069 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:16:02.402212 client.go:110: Initializing new client
[sarama] 2018/12/29 12:16:02.402363 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:16:02.402561 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:16:02.402642 client.go:601: client/metadata fetching metadata for all topics from broker kafka1external:9093
[sarama] 2018/12/29 12:16:02.404311 broker.go:146: Connected to broker at kafka1external:9093 (unregistered)
[sarama] 2018/12/29 12:16:02.406515 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 12:16:02.406529 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 12:16:02.406536 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 12:16:02.406542 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 12:16:02.406556 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 12:16:02.406745 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:17:02.891396 client.go:110: Initializing new client
[sarama] 2018/12/29 12:17:02.891412 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:17:02.891466 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:17:02.891494 client.go:601: client/metadata fetching metadata for all topics from broker kafka3external:9095
[sarama] 2018/12/29 12:17:02.893422 broker.go:146: Connected to broker at kafka3external:9095 (unregistered)
[sarama] 2018/12/29 12:17:02.894486 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 12:17:02.894511 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 12:17:02.894517 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 12:17:02.894523 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 12:17:02.894536 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 12:17:02.894791 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:18:03.411099 client.go:110: Initializing new client
[sarama] 2018/12/29 12:18:03.411112 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:18:03.411160 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:18:03.411190 client.go:601: client/metadata fetching metadata for all topics from broker kafka3external:9095
[sarama] 2018/12/29 12:18:03.412337 broker.go:146: Connected to broker at kafka3external:9095 (unregistered)
[sarama] 2018/12/29 12:18:03.414035 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 12:18:03.414051 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 12:18:03.414057 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 12:18:03.414063 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 12:18:03.414076 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 12:18:03.414236 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:19:03.911613 client.go:110: Initializing new client
[sarama] 2018/12/29 12:19:03.911626 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:19:03.911675 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:19:03.911704 client.go:601: client/metadata fetching metadata for all topics from broker kafka1external:9093
[sarama] 2018/12/29 12:19:03.913447 broker.go:146: Connected to broker at kafka1external:9093 (unregistered)
[sarama] 2018/12/29 12:19:03.914715 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 12:19:03.914734 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 12:19:03.914741 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 12:19:03.914746 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 12:19:03.914791 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 12:19:03.914994 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:19:03.915069 async_producer.go:584: producer/broker/2 starting up
[sarama] 2018/12/29 12:19:03.915085 async_producer.go:596: producer/broker/2 state change to [open] on testchainid/0
[sarama] 2018/12/29 12:20:04.425677 client.go:110: Initializing new client
[sarama] 2018/12/29 12:20:04.425698 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:20:04.425751 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:20:04.425783 client.go:601: client/metadata fetching metadata for all topics from broker kafka2external:9094
[sarama] 2018/12/29 12:20:04.427754 broker.go:146: Connected to broker at kafka2external:9094 (unregistered)
[sarama] 2018/12/29 12:20:04.428644 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 12:20:04.428670 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 12:20:04.428678 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 12:20:04.428686 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 12:20:04.428706 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 12:20:04.429233 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:21:04.947821 client.go:110: Initializing new client
[sarama] 2018/12/29 12:21:04.947833 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:21:04.947951 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:21:04.947982 client.go:601: client/metadata fetching metadata for all topics from broker kafka1external:9093
[sarama] 2018/12/29 12:21:04.949123 broker.go:146: Connected to broker at kafka1external:9093 (unregistered)
[sarama] 2018/12/29 12:21:04.950761 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 12:21:04.950781 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 12:21:04.950788 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 12:21:04.950794 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 12:21:04.950807 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 12:21:04.951093 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:21:04.951241 async_producer.go:584: producer/broker/2 starting up
[sarama] 2018/12/29 12:21:04.951258 async_producer.go:596: producer/broker/2 state change to [open] on testchainid/0
[sarama] 2018/12/29 12:22:05.458130 client.go:110: Initializing new client
[sarama] 2018/12/29 12:22:05.458142 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:22:05.458374 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:22:05.458538 client.go:601: client/metadata fetching metadata for all topics from broker kafka0external:9092
[sarama] 2018/12/29 12:22:05.460471 broker.go:146: Connected to broker at kafka0external:9092 (unregistered)
[sarama] 2018/12/29 12:22:05.461582 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 12:22:05.461606 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 12:22:05.461612 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 12:22:05.461619 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 12:22:05.461637 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 12:22:05.462242 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:23:05.994129 client.go:110: Initializing new client
[sarama] 2018/12/29 12:23:05.994153 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:23:05.994219 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.
[sarama] 2018/12/29 12:23:05.994246 client.go:601: client/metadata fetching metadata for all topics from broker kafka2external:9094
[sarama] 2018/12/29 12:23:05.995830 broker.go:146: Connected to broker at kafka2external:9094 (unregistered)
[sarama] 2018/12/29 12:23:05.997072 client.go:397: client/brokers registered new broker #0 at kafka0external:9092
[sarama] 2018/12/29 12:23:05.997089 client.go:397: client/brokers registered new broker #1 at kafka1external:9093
[sarama] 2018/12/29 12:23:05.997096 client.go:397: client/brokers registered new broker #2 at kafka2external:9094
[sarama] 2018/12/29 12:23:05.997101 client.go:397: client/brokers registered new broker #3 at kafka3external:9095
[sarama] 2018/12/29 12:23:05.997118 client.go:154: Successfully initialized new client
[sarama] 2018/12/29 12:23:05.997316 config.go:329: ClientID is the default of 'sarama', you should consider setting it to something application-specific.