%7|1558951329.003|STATE|hehetest#producer-14| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state APIVERSION_QUERY -> UP
%7|1558951329.003|BROADCAST|hehetest#producer-14| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1558951329.003|METADATA|hehetest#producer-14| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Request metadata for brokers only: connected
%7|1558951329.003|SEND|hehetest#producer-14| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Sent MetadataRequest (v2, 26 bytes @ 0, CorrId 2)
%7|1558951329.003|RECV|hehetest#producer-14| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received MetadataResponse (v2, 71 bytes, CorrId 2, rtt 0.38ms)
%7|1558951329.003|METADATA|hehetest#producer-14| [thrd:main]: localhost:9092/bootstrap: ===== Received metadata: connected =====
%7|1558951329.004|METADATA|hehetest#producer-14| [thrd:main]: localhost:9092/bootstrap: ClusterId: jNahqqPiSEeQS0z-2_0ALw, ControllerId: 0
%7|1558951329.004|METADATA|hehetest#producer-14| [thrd:main]: localhost:9092/bootstrap: 1 brokers, 0 topics
%7|1558951329.004|METADATA|hehetest#producer-14| [thrd:main]: localhost:9092/bootstrap:   Broker #0/1: MY_HOST:9092 NodeId 0
%7|1558951329.004|WAKEUPFD|hehetest#producer-14| [thrd:main]: MY_HOST:9092/0: Enabled low-latency ops queue wake-ups
%7|1558951329.005|BROKER|hehetest#producer-14| [thrd:main]: MY_HOST:9092/0: Added new broker with NodeId 0
%7|1558951329.005|CLUSTERID|hehetest#producer-14| [thrd:main]: localhost:9092/bootstrap: ClusterId update "" -> "jNahqqPiSEeQS0z-2_0ALw"
%7|1558951329.005|CONTROLLERID|hehetest#producer-14| [thrd:main]: localhost:9092/bootstrap: ControllerId update -1 -> 0
%7|1558951329.005|BROADCAST|hehetest#producer-14| [thrd:main]: Broadcasting state change
%7|1558951329.005|BRKMAIN|hehetest#producer-14| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Enter main broker thread
%7|1558951330.637|DESTROY|hehetest#producer-14| [thrd:app]: Terminating instance (destroy flags none (0x0))
%7|1558951330.637|TERMINATE|hehetest#producer-14| [thrd:app]: Interrupting timers
%7|1558951330.637|TERMINATE|hehetest#producer-14| [thrd:app]: Sending TERMINATE to internal main thread
%7|1558951330.637|TERMINATE|hehetest#producer-14| [thrd:app]: Joining internal main thread
%7|1558951330.637|TERMINATE|hehetest#producer-14| [thrd:main]: Internal main thread terminating
%7|1558951330.637|DESTROY|hehetest#producer-14| [thrd:main]: Destroy internal
%7|1558951330.637|BROADCAST|hehetest#producer-14| [thrd:main]: Broadcasting state change
%7|1558951330.637|DESTROY|hehetest#producer-14| [thrd:main]: Removing all topics
%7|1558951330.637|DESTROY|hehetest#producer-14| [thrd:main]: Sending TERMINATE to MY_HOST:9092/0
%7|1558951330.637|DESTROY|hehetest#producer-14| [thrd:main]: Sending TERMINATE to localhost:9092/bootstrap
%7|1558951330.637|TERM|hehetest#producer-14| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Received TERMINATE op in state INIT: 1 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs
%7|1558951330.637|TERMINATE|hehetest#producer-14| [thrd:main]: Purging reply queue
%7|1558951330.637|TERMINATE|hehetest#producer-14| [thrd:main]: Decommissioning internal broker
%7|1558951330.637|BROKERFAIL|hehetest#producer-14| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: failed: err: Local: Broker handle destroyed: (errno: Success)
%7|1558951330.637|TERM|hehetest#producer-14| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received TERMINATE op in state UP: 1 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs
%7|1558951330.637|FAIL|hehetest#producer-14| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Client is terminating (after 1633ms in state INIT)
%7|1558951330.637|TERMINATE|hehetest#producer-14| [thrd:main]: Join 3 broker thread(s)
%7|1558951330.637|STATE|hehetest#producer-14| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Broker changed state INIT -> DOWN
%7|1558951330.637|BROKERFAIL|hehetest#producer-14| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: failed: err: Local: Broker handle destroyed: (errno: Resource temporarily unavailable)
%7|1558951330.637|TERM|hehetest#producer-14| [thrd::0/internal]: :0/internal: Received TERMINATE op in state INIT: 1 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs
%7|1558951330.637|BROADCAST|hehetest#producer-14| [thrd:MY_HOST:9092/0]: Broadcasting state change
%7|1558951330.637|BUFQ|hehetest#producer-14| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Purging bufq with 0 buffers
%7|1558951330.637|BUFQ|hehetest#producer-14| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Purging bufq with 0 buffers
%7|1558951330.637|BUFQ|hehetest#producer-14| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Updating 0 buffers on connection reset
%7|1558951330.637|BROKERFAIL|hehetest#producer-14| [thrd::0/internal]: :0/internal: failed: err: Local: Broker handle destroyed: (errno: Success)
%7|1558951330.637|FAIL|hehetest#producer-14| [thrd::0/internal]: :0/internal: Client is terminating (after 1640ms in state INIT)
%7|1558951330.637|STATE|hehetest#producer-14| [thrd::0/internal]: :0/internal: Broker changed state INIT -> DOWN
%7|1558951330.637|TERMINATE|hehetest#producer-14| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Handle is terminating in state DOWN: 1 refcnts (0x7fd852e76310), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf
%7|1558951330.637|BROADCAST|hehetest#producer-14| [thrd::0/internal]: Broadcasting state change
%7|1558951330.637|BROKERFAIL|hehetest#producer-14| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: failed: err: Local: Broker handle destroyed: (errno: Success)
%7|1558951330.637|BUFQ|hehetest#producer-14| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Purging bufq with 0 buffers
%7|1558951330.637|BUFQ|hehetest#producer-14| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Purging bufq with 0 buffers
%7|1558951330.637|BUFQ|hehetest#producer-14| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Updating 0 buffers on connection reset
%7|1558951330.637|BUFQ|hehetest#producer-14| [thrd::0/internal]: :0/internal: Purging bufq with 0 buffers
%7|1558951330.637|BUFQ|hehetest#producer-14| [thrd::0/internal]: :0/internal: Purging bufq with 0 buffers
%7|1558951330.637|BUFQ|hehetest#producer-14| [thrd::0/internal]: :0/internal: Updating 0 buffers on connection reset
%7|1558951330.637|TERMINATE|hehetest#producer-14| [thrd::0/internal]: :0/internal: Handle is terminating in state DOWN: 1 refcnts (0x7fd85bbd5710), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf
%7|1558951330.637|FAIL|hehetest#producer-14| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Client is terminating (after 1634ms in state UP)
%7|1558951330.637|BROKERFAIL|hehetest#producer-14| [thrd::0/internal]: :0/internal: failed: err: Local: Broker handle destroyed: (errno: Success)
%7|1558951330.637|BUFQ|hehetest#producer-14| [thrd::0/internal]: :0/internal: Purging bufq with 0 buffers
%7|1558951330.637|STATE|hehetest#producer-14| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state UP -> DOWN
%7|1558951330.637|BUFQ|hehetest#producer-14| [thrd::0/internal]: :0/internal: Purging bufq with 0 buffers
%7|1558951330.637|BROADCAST|hehetest#producer-14| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1558951330.637|BUFQ|hehetest#producer-14| [thrd::0/internal]: :0/internal: Updating 0 buffers on connection reset
%7|1558951330.637|BUFQ|hehetest#producer-14| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
%7|1558951330.637|BUFQ|hehetest#producer-14| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
%7|1558951330.637|BUFQ|hehetest#producer-14| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updating 0 buffers on connection reset
%7|1558951330.637|TERMINATE|hehetest#producer-14| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Handle is terminating in state DOWN: 1 refcnts (0x7fd85bbd9310), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf
%7|1558951330.637|BROKERFAIL|hehetest#producer-14| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: failed: err: Local: Broker handle destroyed: (errno: Resource temporarily unavailable)
%7|1558951330.637|BUFQ|hehetest#producer-14| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
%7|1558951330.637|BUFQ|hehetest#producer-14| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
%7|1558951330.637|BUFQ|hehetest#producer-14| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updating 0 buffers on connection reset
%7|1558951330.638|TERMINATE|hehetest#producer-14| [thrd:main]: Internal main thread termination done
%7|1558951330.639|TERMINATE|hehetest#producer-14| [thrd:app]: Destroying op queues
%7|1558951330.639|TERMINATE|hehetest#producer-14| [thrd:app]: Termination done: freeing resources
%7|1558951348.577|WAKEUPFD|hehetest#producer-15| [thrd:app]: localhost:9092/bootstrap: Enabled low-latency ops queue wake-ups
%7|1558951348.577|BRKMAIN|hehetest#producer-15| [thrd::0/internal]: :0/internal: Enter main broker thread
%7|1558951348.578|BROKER|hehetest#producer-15| [thrd:app]: localhost:9092/bootstrap: Added new broker with NodeId -1
%7|1558951348.578|CONNECT|hehetest#producer-15| [thrd:app]: localhost:9092/bootstrap: Selected for cluster connection: bootstrap servers added (broker has 0 connection attempt(s))
%7|1558951348.578|INIT|hehetest#producer-15| [thrd:app]: librdkafka v1.0.0 (0x10000ff) hehetest#producer-15 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_plain,sasl_scram,plugins, GCC GXX PKGCONFIG INSTALL GNULD LDS LIBDL PLUGINS ZLIB SSL HDRHISTOGRAM SNAPPY SOCKEM SASL_SCRAM CRC32C_HW, debug 0xffff)
%7|1558951348.578|BRKMAIN|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enter main broker thread
%7|1558951348.578|CONNECT|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op
%7|1558951348.578|STATE|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT
%7|1558951348.578|BROADCAST|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1558951348.578|CONNECT|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting
%7|1558951348.578|STATE|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
%7|1558951348.578|BROADCAST|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1558951348.579|CONNECT|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 198
%7|1558951348.579|CONNECT|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected to ipv4#127.0.0.1:9092
%7|1558951348.579|CONNECTED|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected (#1)
%7|1558951348.579|FEATURE|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion
%7|1558951348.579|STATE|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY
%7|1558951348.579|BROADCAST|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1558951348.579|SEND|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Sent ApiVersionRequest (v0, 26 bytes @ 0, CorrId 1)
%7|1558951348.580|RECV|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received ApiVersionResponse (v0, 264 bytes, CorrId 1, rtt 1.17ms)
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker API support:
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey Produce (0) Versions 0..7
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey Fetch (1) Versions 0..10
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey Offset (2) Versions 0..4
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey Metadata (3) Versions 0..7
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey LeaderAndIsr (4) Versions 0..1
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey StopReplica (5) Versions 0..0
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey UpdateMetadata (6) Versions 0..4
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey ControlledShutdown (7) Versions 0..1
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey OffsetCommit (8) Versions 0..6
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey OffsetFetch (9) Versions 0..5
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey GroupCoordinator (10) Versions 0..2
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey JoinGroup (11) Versions 0..3
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey Heartbeat (12) Versions 0..2
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey LeaveGroup (13) Versions 0..2
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey SyncGroup (14) Versions 0..2
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DescribeGroups (15) Versions 0..2
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey ListGroups (16) Versions 0..2
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey SaslHandshake (17) Versions 0..1
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey ApiVersion (18) Versions 0..2
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey CreateTopics (19) Versions 0..3
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DeleteTopics (20) Versions 0..3
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DeleteRecords (21) Versions 0..1
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey InitProducerId (22) Versions 0..1
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey OffsetForLeaderEpoch (23) Versions 0..2
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey AddPartitionsToTxn (24) Versions 0..1
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey AddOffsetsToTxn (25) Versions 0..1
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey EndTxn (26) Versions 0..1
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey WriteTxnMarkers (27) Versions 0..0
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey TxnOffsetCommit (28) Versions 0..2
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DescribeAcls (29) Versions 0..1
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey CreateAcls (30) Versions 0..1
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DeleteAcls (31) Versions 0..1
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DescribeConfigs (32) Versions 0..2
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey AlterConfigs (33) Versions 0..1
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey AlterReplicaLogDirs (34) Versions 0..1
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DescribeLogDirs (35) Versions 0..1
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey SaslAuthenticate (36) Versions 0..0
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey CreatePartitions (37) Versions 0..1
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey CreateDelegationToken (38) Versions 0..1
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey RenewDelegationToken (39) Versions 0..1
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey ExpireDelegationToken (40) Versions 0..1
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DescribeDelegationToken (41) Versions 0..1
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:   ApiKey DeleteGroups (42) Versions 0..1
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature MsgVer1: Produce (2..2) supported by broker
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature MsgVer1: Fetch (2..2) supported by broker
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature MsgVer1
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature MsgVer2: Produce (3..3) supported by broker
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature MsgVer2: Fetch (4..4) supported by broker
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature MsgVer2
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature ApiVersion: ApiVersion (0..0) supported by broker
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature ApiVersion
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerGroupCoordinator: GroupCoordinator (0..0) supported by broker
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature BrokerGroupCoordinator
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: GroupCoordinator (0..0) supported by broker
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature BrokerBalancedConsumer
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature ThrottleTime: Produce (1..2) supported by broker
%7|1558951348.580|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1558951348.581|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature ThrottleTime
%7|1558951348.581|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature Sasl: JoinGroup (0..0) supported by broker
%7|1558951348.581|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature Sasl
%7|1558951348.581|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1558951348.581|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature SaslHandshake
%7|1558951348.581|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature LZ4: GroupCoordinator (0..0) supported by broker
%7|1558951348.581|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature LZ4
%7|1558951348.581|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature OffsetTime: Offset (1..1) supported by broker
%7|1558951348.581|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature OffsetTime
%7|1558951348.581|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature IdempotentProducer: InitProducerId (0..0) supported by broker
%7|1558951348.581|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature IdempotentProducer
%7|1558951348.581|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature ZSTD: Produce (7..7) supported by broker
%7|1558951348.581|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap:  Feature ZSTD: Fetch (10..10) supported by broker
%7|1558951348.581|APIVERSION|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enabling feature ZSTD
%7|1558951348.581|FEATURE|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD
%7|1558951348.581|STATE|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state APIVERSION_QUERY -> UP
%7|1558951348.581|BROADCAST|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1558951348.581|METADATA|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Request metadata for brokers only: connected
%7|1558951348.581|SEND|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Sent MetadataRequest (v2, 26 bytes @ 0, CorrId 2)
%7|1558951348.581|RECV|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received MetadataResponse (v2, 71 bytes, CorrId 2, rtt 0.42ms)
%7|1558951348.581|METADATA|hehetest#producer-15| [thrd:main]: localhost:9092/bootstrap: ===== Received metadata: connected =====
%7|1558951348.581|METADATA|hehetest#producer-15| [thrd:main]: localhost:9092/bootstrap: ClusterId: jNahqqPiSEeQS0z-2_0ALw, ControllerId: 0
%7|1558951348.581|METADATA|hehetest#producer-15| [thrd:main]: localhost:9092/bootstrap: 1 brokers, 0 topics
%7|1558951348.581|METADATA|hehetest#producer-15| [thrd:main]: localhost:9092/bootstrap:   Broker #0/1: MY_HOST:9092 NodeId 0
%7|1558951348.581|WAKEUPFD|hehetest#producer-15| [thrd:main]: MY_HOST:9092/0: Enabled low-latency ops queue wake-ups
%7|1558951348.583|BROKER|hehetest#producer-15| [thrd:main]: MY_HOST:9092/0: Added new broker with NodeId 0
%7|1558951348.583|CLUSTERID|hehetest#producer-15| [thrd:main]: localhost:9092/bootstrap: ClusterId update "" -> "jNahqqPiSEeQS0z-2_0ALw"
%7|1558951348.583|CONTROLLERID|hehetest#producer-15| [thrd:main]: localhost:9092/bootstrap: ControllerId update -1 -> 0
%7|1558951348.583|BROADCAST|hehetest#producer-15| [thrd:main]: Broadcasting state change
%7|1558951348.583|BRKMAIN|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Enter main broker thread
%7|1558951356.736|TOPIC|hehetest#producer-15| [thrd:app]: New local topic: MY_TOPIC_NAME
%7|1558951356.736|TOPPARNEW|hehetest#producer-15| [thrd:app]: NEW MY_TOPIC_NAME [-1] 0x7fd85bc05000 (at rd_kafka_topic_new0:393)
%7|1558951356.736|METADATA|hehetest#producer-15| [thrd:app]: Hinted cache of 1/1 topic(s) being queried
%7|1558951356.736|METADATA|hehetest#producer-15| [thrd:app]: Requesting metadata for 1/1 topics: leader query
%7|1558951356.736|METADATA|hehetest#producer-15| [thrd:app]: localhost:9092/bootstrap: Request metadata for 1 topic(s): leader query
%7|1558951356.737|SEND|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Sent MetadataRequest (v2, 41 bytes @ 0, CorrId 3)
%7|1558951356.737|RECV|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received MetadataResponse (v2, 119 bytes, CorrId 3, rtt 0.76ms)
%7|1558951356.737|METADATA|hehetest#producer-15| [thrd:main]: localhost:9092/bootstrap: ===== Received metadata (for 1 requested topics): leader query =====
%7|1558951356.738|METADATA|hehetest#producer-15| [thrd:main]: localhost:9092/bootstrap: ClusterId: jNahqqPiSEeQS0z-2_0ALw, ControllerId: 0
%7|1558951356.738|METADATA|hehetest#producer-15| [thrd:main]: localhost:9092/bootstrap: 1 brokers, 1 topics
%7|1558951356.738|METADATA|hehetest#producer-15| [thrd:main]: localhost:9092/bootstrap:   Broker #0/1: MY_HOST:9092 NodeId 0
%7|1558951356.738|METADATA|hehetest#producer-15| [thrd:main]: localhost:9092/bootstrap:   Topic #0/1: MY_TOPIC_NAME with 1 partitions
%7|1558951356.738|STATE|hehetest#producer-15| [thrd:main]: Topic MY_TOPIC_NAME changed state unknown -> exists
%7|1558951356.738|PARTCNT|hehetest#producer-15| [thrd:main]: Topic MY_TOPIC_NAME partition count changed from 0 to 1
%7|1558951356.738|TOPPARNEW|hehetest#producer-15| [thrd:main]: NEW MY_TOPIC_NAME [0] 0x7fd513708e80 (at rd_kafka_topic_partition_cnt_update:620)
%7|1558951356.738|METADATA|hehetest#producer-15| [thrd:main]:   Topic MY_TOPIC_NAME partition 0 Leader 0
%7|1558951356.738|BRKDELGT|hehetest#producer-15| [thrd:main]: MY_TOPIC_NAME [0]: delegate to broker MY_HOST:9092/0 (rktp 0x7fd513708e80, term 0, ref 2, remove 0)
%7|1558951356.738|BRKDELGT|hehetest#producer-15| [thrd:main]: MY_TOPIC_NAME [0]: broker MY_HOST:9092/0 is now leader for partition with 0 messages (0 bytes) queued
%7|1558951356.738|BRKMIGR|hehetest#producer-15| [thrd:main]: Migrating topic MY_TOPIC_NAME [0] 0x7fd513708e80 from (none) to MY_HOST:9092/0 (sending PARTITION_JOIN to MY_HOST:9092/0)
%7|1558951356.738|PARTCNT|hehetest#producer-15| [thrd:main]: Partitioning 0 unassigned messages in topic MY_TOPIC_NAME to 1 partitions
%7|1558951356.738|UAS|hehetest#producer-15| [thrd:main]: 0/0 messages were partitioned in topic MY_TOPIC_NAME
%7|1558951356.738|TOPBRK|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Topic MY_TOPIC_NAME [0]: joining broker (rktp 0x7fd513708e80, 0 message(s) queued)
%7|1558951356.738|FETCHADD|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Added MY_TOPIC_NAME [0] to active list (1 entries, opv 0, 0 messages queued)
%7|1558951356.738|BROADCAST|hehetest#producer-15| [thrd:MY_HOST:9092/0]: Broadcasting state change
%7|1558951356.738|METADATA|hehetest#producer-15| [thrd:main]: localhost:9092/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1558951362.100|TOPPAR|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: MY_TOPIC_NAME [0] 1 message(s) in xmit queue (1 added from partition queue)
%7|1558951362.100|TOPPAR|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: MY_TOPIC_NAME [0] 1 message(s) queued but broker not up
%7|1558951362.100|STATE|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Broker changed state INIT -> TRY_CONNECT
%7|1558951362.100|BROADCAST|hehetest#producer-15| [thrd:MY_HOST:9092/0]: Broadcasting state change
%7|1558951362.100|CONNECT|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: broker in state TRY_CONNECT connecting
%7|1558951362.100|STATE|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Broker changed state TRY_CONNECT -> CONNECT
%7|1558951362.100|BROADCAST|hehetest#producer-15| [thrd:MY_HOST:9092/0]: Broadcasting state change
%7|1558951362.100|CONNECT|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Connecting to ipv4#10.60.47.127:9092 (plaintext) with socket 206
%7|1558951362.101|TOPPAR|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: MY_TOPIC_NAME [0] 1 message(s) in xmit queue (0 added from partition queue)
%7|1558951362.101|TOPPAR|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: MY_TOPIC_NAME [0] 1 message(s) queued but broker not up
%7|1558951362.101|CONNECT|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Connected to ipv4#10.60.47.127:9092
%7|1558951362.101|CONNECTED|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Connected (#1)
%7|1558951362.101|FEATURE|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Updated enabled protocol features +ApiVersion to ApiVersion
%7|1558951362.101|STATE|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Broker changed state CONNECT -> APIVERSION_QUERY
%7|1558951362.101|BROADCAST|hehetest#producer-15| [thrd:MY_HOST:9092/0]: Broadcasting state change
%7|1558951362.101|SEND|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Sent ApiVersionRequest (v0, 26 bytes @ 0, CorrId 1)
%7|1558951362.101|TOPPAR|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: MY_TOPIC_NAME [0] 1 message(s) in xmit queue (0 added from partition queue)
%7|1558951362.101|TOPPAR|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: MY_TOPIC_NAME [0] 1 message(s) queued but broker not up
%7|1558951362.102|RECV|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Received ApiVersionResponse (v0, 264 bytes, CorrId 1, rtt 0.96ms)
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Broker API support:
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey Produce (0) Versions 0..7
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey Fetch (1) Versions 0..10
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey Offset (2) Versions 0..4
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey Metadata (3) Versions 0..7
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey LeaderAndIsr (4) Versions 0..1
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey StopReplica (5) Versions 0..0
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey UpdateMetadata (6) Versions 0..4
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey ControlledShutdown (7) Versions 0..1
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey OffsetCommit (8) Versions 0..6
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey OffsetFetch (9) Versions 0..5
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey GroupCoordinator (10) Versions 0..2
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey JoinGroup (11) Versions 0..3
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey Heartbeat (12) Versions 0..2
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey LeaveGroup (13) Versions 0..2
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey SyncGroup (14) Versions 0..2
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey DescribeGroups (15) Versions 0..2
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey ListGroups (16) Versions 0..2
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey SaslHandshake (17) Versions 0..1
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey ApiVersion (18) Versions 0..2
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey CreateTopics (19) Versions 0..3
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey DeleteTopics (20) Versions 0..3
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey DeleteRecords (21) Versions 0..1
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey InitProducerId (22) Versions 0..1
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey OffsetForLeaderEpoch (23) Versions 0..2
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey AddPartitionsToTxn (24) Versions 0..1
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey AddOffsetsToTxn (25) Versions 0..1
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey EndTxn (26) Versions 0..1
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey WriteTxnMarkers (27) Versions 0..0
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey TxnOffsetCommit (28) Versions 0..2
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey DescribeAcls (29) Versions 0..1
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey CreateAcls (30) Versions 0..1
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey DeleteAcls (31) Versions 0..1
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey DescribeConfigs (32) Versions 0..2
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey AlterConfigs (33) Versions 0..1
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey AlterReplicaLogDirs (34) Versions 0..1
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey DescribeLogDirs (35) Versions 0..1
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey SaslAuthenticate (36) Versions 0..0
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey CreatePartitions (37) Versions 0..1
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey CreateDelegationToken (38) Versions 0..1
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey RenewDelegationToken (39) Versions 0..1
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey ExpireDelegationToken (40) Versions 0..1
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey DescribeDelegationToken (41) Versions 0..1
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:   ApiKey DeleteGroups (42) Versions 0..1
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:  Feature MsgVer1: Produce (2..2) supported by broker
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:  Feature MsgVer1: Fetch (2..2) supported by broker
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Enabling feature MsgVer1
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:  Feature MsgVer2: Produce (3..3) supported by broker
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:  Feature MsgVer2: Fetch (4..4) supported by broker
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Enabling feature MsgVer2
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:  Feature ApiVersion: ApiVersion (0..0) supported by broker
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Enabling feature ApiVersion
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:  Feature BrokerGroupCoordinator: GroupCoordinator (0..0) supported by broker
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Enabling feature BrokerGroupCoordinator
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:  Feature BrokerBalancedConsumer: GroupCoordinator (0..0) supported by broker
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:  Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:  Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:  Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:  Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:  Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:  Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Enabling feature BrokerBalancedConsumer
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:  Feature ThrottleTime: Produce (1..2) supported by broker
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:  Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Enabling feature ThrottleTime
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:  Feature Sasl: JoinGroup (0..0) supported by broker
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Enabling feature Sasl
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:  Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Enabling feature SaslHandshake
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:  Feature LZ4: GroupCoordinator (0..0) supported by broker
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Enabling feature LZ4
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:  Feature OffsetTime: Offset (1..1) supported by broker
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Enabling feature OffsetTime
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:  Feature IdempotentProducer: InitProducerId (0..0) supported by broker
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Enabling feature IdempotentProducer
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:  Feature ZSTD: Produce (7..7) supported by broker
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0:  Feature ZSTD: Fetch (10..10) supported by broker
%7|1558951362.102|APIVERSION|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Enabling feature ZSTD
%7|1558951362.102|FEATURE|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD
%7|1558951362.102|STATE|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Broker changed state APIVERSION_QUERY -> UP
%7|1558951362.102|BROADCAST|hehetest#producer-15| [thrd:MY_HOST:9092/0]: Broadcasting state change
%7|1558951362.102|METADATA|hehetest#producer-15| [thrd:MY_HOST:9092/0]: Skipping metadata refresh of 1 topic(s): connected: already being requested
%7|1558951362.102|TOPPAR|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: MY_TOPIC_NAME [0] 1 message(s) in xmit queue (0 added from partition queue)
%7|1558951362.102|PRODUCE|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: MY_TOPIC_NAME [0]: Produce MessageSet with 1 message(s) (161 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid})
%7|1558951362.102|SEND|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Sent ProduceRequest (v7, 222 bytes @ 0, CorrId 2)
%7|1558951362.103|RECV|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Received ProduceResponse (v7, 57 bytes, CorrId 2, rtt 0.84ms)
%7|1558951362.103|MSGSET|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: MY_TOPIC_NAME [0]: MessageSet with 1 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1558951362.670|TOPPAR|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: MY_TOPIC_NAME [0] 1 message(s) in xmit queue (1 added from partition queue)
%7|1558951362.670|PRODUCE|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: MY_TOPIC_NAME [0]: Produce MessageSet with 1 message(s) (161 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid})
%7|1558951362.670|SEND|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Sent ProduceRequest (v7, 222 bytes @ 0, CorrId 3)
%7|1558951362.671|RECV|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Received ProduceResponse (v7, 57 bytes, CorrId 3, rtt 0.79ms)
%7|1558951362.671|MSGSET|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: MY_TOPIC_NAME [0]: MessageSet with 1 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1558951363.223|TOPPAR|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: MY_TOPIC_NAME [0] 1 message(s) in xmit queue (1 added from partition queue)
%7|1558951363.224|PRODUCE|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: MY_TOPIC_NAME [0]: Produce MessageSet with 1 message(s) (161 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid})
%7|1558951363.224|SEND|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Sent ProduceRequest (v7, 222 bytes @ 0, CorrId 4)
%7|1558951363.226|RECV|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Received ProduceResponse (v7, 57 bytes, CorrId 4, rtt 1.82ms)
%7|1558951363.226|MSGSET|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: MY_TOPIC_NAME [0]: MessageSet with 1 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1558951363.790|TOPPAR|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: MY_TOPIC_NAME [0] 1 message(s) in xmit queue (1 added from partition queue)
%7|1558951363.790|PRODUCE|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: MY_TOPIC_NAME [0]: Produce MessageSet with 1 message(s) (161 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid})
%7|1558951363.790|SEND|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Sent ProduceRequest (v7, 222 bytes @ 0, CorrId 5)
%7|1558951363.791|RECV|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Received ProduceResponse (v7, 57 bytes, CorrId 5, rtt 0.93ms)
%7|1558951363.791|MSGSET|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: MY_TOPIC_NAME [0]: MessageSet with 1 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1558951364.321|TOPPAR|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: MY_TOPIC_NAME [0] 1 message(s) in xmit queue (1 added from partition queue)
%7|1558951364.321|PRODUCE|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: MY_TOPIC_NAME [0]: Produce MessageSet with 1 message(s) (161 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid})
%7|1558951364.321|SEND|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Sent ProduceRequest (v7, 222 bytes @ 0, CorrId 6)
%7|1558951364.322|RECV|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Received ProduceResponse (v7, 57 bytes, CorrId 6, rtt 1.14ms)
%7|1558951364.322|MSGSET|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: MY_TOPIC_NAME [0]: MessageSet with 1 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1558951648.576|METADATA|hehetest#producer-15| [thrd:main]: Requesting metadata for 1/1 topics: periodic refresh
%7|1558951648.576|METADATA|hehetest#producer-15| [thrd:main]: MY_HOST:9092/0: Request metadata for 1 topic(s): periodic refresh
%7|1558951648.576|SEND|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Sent MetadataRequest (v2, 41 bytes @ 0, CorrId 7)
%7|1558951648.577|RECV|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Received MetadataResponse (v2, 119 bytes, CorrId 7, rtt 0.89ms)
%7|1558951648.577|METADATA|hehetest#producer-15| [thrd:main]: MY_HOST:9092/0: ===== Received metadata (for 1 requested topics): periodic refresh =====
%7|1558951648.577|METADATA|hehetest#producer-15| [thrd:main]: MY_HOST:9092/0: ClusterId: jNahqqPiSEeQS0z-2_0ALw, ControllerId: 0
%7|1558951648.577|METADATA|hehetest#producer-15| [thrd:main]: MY_HOST:9092/0: 1 brokers, 1 topics
%7|1558951648.577|METADATA|hehetest#producer-15| [thrd:main]: MY_HOST:9092/0:   Broker #0/1: MY_HOST:9092 NodeId 0
%7|1558951648.577|METADATA|hehetest#producer-15| [thrd:main]: MY_HOST:9092/0:   Topic #0/1: MY_TOPIC_NAME with 1 partitions
%7|1558951648.577|METADATA|hehetest#producer-15| [thrd:main]:   Topic MY_TOPIC_NAME partition 0 Leader 0
%7|1558951648.577|METADATA|hehetest#producer-15| [thrd:main]: MY_HOST:9092/0: 1/1 requested topic(s) seen in metadata
%7|1558951656.768|DESTROY|hehetest#producer-15| [thrd:app]: Terminating instance (destroy flags none (0x0))
%7|1558951656.768|TERMINATE|hehetest#producer-15| [thrd:app]: Interrupting timers
%7|1558951656.768|TERMINATE|hehetest#producer-15| [thrd:app]: Sending TERMINATE to internal main thread
%7|1558951656.768|TERMINATE|hehetest#producer-15| [thrd:app]: Joining internal main thread
%7|1558951656.768|TERMINATE|hehetest#producer-15| [thrd:main]: Internal main thread terminating
%7|1558951656.768|DESTROY|hehetest#producer-15| [thrd:main]: Destroy internal
%7|1558951656.768|BROADCAST|hehetest#producer-15| [thrd:main]: Broadcasting state change
%7|1558951656.768|DESTROY|hehetest#producer-15| [thrd:main]: Removing all topics
%7|1558951656.768|PARTCNT|hehetest#producer-15| [thrd:main]: Topic MY_TOPIC_NAME partition count changed from 1 to 0
%7|1558951656.768|REMOVE|hehetest#producer-15| [thrd:main]: MY_TOPIC_NAME [0] no longer reported in metadata
%7|1558951656.768|BRKMIGR|hehetest#producer-15| [thrd:main]: MY_TOPIC_NAME [0] 0x7fd513708e80 sending final LEAVE for removal by MY_HOST:9092/0
%7|1558951656.768|TOPPARREMOVE|hehetest#producer-15| [thrd:main]: Removing toppar MY_TOPIC_NAME [-1] 0x7fd85bc05000
%7|1558951656.768|DESTROY|hehetest#producer-15| [thrd:main]: MY_TOPIC_NAME [-1]: 0x7fd85bc05000 DESTROY_FINAL
%7|1558951656.768|DESTROY|hehetest#producer-15| [thrd:main]: Sending TERMINATE to MY_HOST:9092/0
%7|1558951656.768|DESTROY|hehetest#producer-15| [thrd:main]: Sending TERMINATE to localhost:9092/bootstrap
%7|1558951656.768|TOPBRK|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Topic MY_TOPIC_NAME [0]: leaving broker (0 messages in xmitq, next leader (none), rktp 0x7fd513708e80)
%7|1558951656.768|TERMINATE|hehetest#producer-15| [thrd:main]: Purging reply queue
%7|1558951656.768|FETCHADD|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Removed MY_TOPIC_NAME [0] from active list (0 entries, opv 0)
%7|1558951656.768|TERMINATE|hehetest#producer-15| [thrd:main]: Decommissioning internal broker
%7|1558951656.768|TOPBRK|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Topic MY_TOPIC_NAME [0]: no next leader, failing 0 message(s) in partition queue
%7|1558951656.768|BROADCAST|hehetest#producer-15| [thrd:MY_HOST:9092/0]: Broadcasting state change
%7|1558951656.768|TOPPARREMOVE|hehetest#producer-15| [thrd:MY_HOST:9092/0]: Removing toppar MY_TOPIC_NAME [0] 0x7fd513708e80
%7|1558951656.768|DESTROY|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_TOPIC_NAME [0]: 0x7fd513708e80 DESTROY_FINAL
%7|1558951656.768|TERMINATE|hehetest#producer-15| [thrd:main]: Join 3 broker thread(s)
%7|1558951656.768|TERM|hehetest#producer-15| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received TERMINATE op in state UP: 1 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs
%7|1558951656.768|TERM|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Received TERMINATE op in state UP: 1 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs
%7|1558951656.768|BROKERFAIL|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: failed: err: Local: Broker handle destroyed: (errno: Resource temporarily unavailable)
%7|1558951656.768|FAIL|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Client is terminating (after 294666ms in state UP)
%7|1558951656.768|STATE|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Broker changed state UP -> DOWN
%7|1558951656.768|BROADCAST|hehetest#producer-15| [thrd:MY_HOST:9092/0]: Broadcasting state change
%7|1558951656.768|BUFQ|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Purging bufq with 0 buffers
%7|1558951656.768|BUFQ|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Purging bufq with 0 buffers
%7|1558951656.768|BUFQ|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Updating 0 buffers on connection reset
%7|1558951656.768|TERM|hehetest#producer-15| [thrd::0/internal]: :0/internal: Received TERMINATE op in state INIT: 1 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs
%7|1558951656.768|TERMINATE|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Handle is terminating in state DOWN: 1 refcnts (0x7fd909da8b10), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf
%7|1558951656.769|BROKERFAIL|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: failed: err: Local: Broker handle destroyed: (errno: Resource temporarily unavailable)
%7|1558951656.769|BUFQ|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Purging bufq with 0 buffers
%7|1558951656.769|BUFQ|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Purging bufq with 0 buffers
%7|1558951656.769|BUFQ|hehetest#producer-15| [thrd:MY_HOST:9092/0]: MY_HOST:9092/0: Updating 0 buffers on connection reset
%7|1558951656.769|BROKERFAIL|hehetest#producer-15| [thrd::0/internal]: :0/internal: failed: err: Local: Broker handle destroyed: (errno: Success)
%7|1558951656.769|FAIL|hehetest#producer-15| [thrd::0/internal]: :0/internal: Client is terminating (after 308193ms in state INIT)
%7|1558951656.769|STATE|hehetest#producer-15| [thrd::0/internal]: :0/internal: Broker changed state INIT -> DOWN
%7|1558951656.769|BROADCAST|hehetest#producer-15| [thrd::0/internal]: Broadcasting state change
%7|1558951656.769|BUFQ|hehetest#producer-15| [thrd::0/internal]: :0/internal: Purging bufq with 0 buffers
%7|1558951656.769|BUFQ|hehetest#producer-15| [thrd::0/internal]: :0/internal: Purging bufq with 0 buffers
%7|1558951656.769|BUFQ|hehetest#producer-15| [thrd::0/internal]: :0/internal: Updating 0 buffers on connection reset
%7|1558951656.769|TERMINATE|hehetest#producer-15| [thrd::0/internal]: :0/internal: Handle is terminating in state DOWN: 1 refcnts (0x7fd852e72710), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf
%7|1558951656.769|BROKERFAIL|hehetest#producer-15| [thrd::0/internal]: :0/internal: failed: err: Local: Broker handle destroyed: (errno: Success)
%7|1558951656.769|BUFQ|hehetest#producer-15| [thrd::0/internal]: :0/internal: Purging bufq with 0 buffers
%7|1558951656.769|BUFQ|hehetest#producer-15| [thrd::0/internal]: :0/internal: Purging bufq with 0 buffers
%7|1558951656.769|BUFQ|hehetest#producer-15| [thrd::0/internal]: :0/internal: Updating 0 buffers on connection reset