%7|1617778132.511|CONF|rdkafka#producer-1| [thrd::0/internal]: Client configuration:
%7|1617778132.511|CONF|rdkafka#producer-1| [thrd::0/internal]:   client.software.version = 1.6.1
%7|1617778132.511|CONF|rdkafka#producer-1| [thrd::0/internal]:   metadata.broker.list = 192.0.1.2:9092
%7|1617778132.511|CONF|rdkafka#producer-1| [thrd::0/internal]:   debug = msg,protocol,conf
%7|1617778132.511|CONF|rdkafka#producer-1| [thrd::0/internal]:   queue.buffering.max.ms = 1000
%7|1617778132.511|CONF|rdkafka#producer-1| [thrd::0/internal]:   batch.num.messages = 1000
%7|1617778132.511|CONF|rdkafka#producer-1| [thrd::0/internal]:   delivery.report.only.error = true
%7|1617778132.515|CONF|rdkafka#producer-1| [thrd:192.0.1.2:9092/bootstrap]: Topic "kpis" configuration (user-supplied):
%7|1617778132.515|CONF|rdkafka#producer-1| [thrd:192.0.1.2:9092/bootstrap]:   request.required.acks = 0
%7|1617778133.514|CONNECTED|rdkafka#producer-1| [thrd:192.0.1.2:9092/bootstrap]: 192.0.1.2:9092/bootstrap: Connected (#1)
%7|1617778133.514|FEATURE|rdkafka#producer-1| [thrd:192.0.1.2:9092/bootstrap]: 192.0.1.2:9092/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion
%7|1617778133.515|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9092/bootstrap]: 192.0.1.2:9092/bootstrap: Sent ApiVersionRequest (v3, 40 bytes @ 0, CorrId 1)
%7|1617778134.517|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9092/bootstrap]: 192.0.1.2:9092/bootstrap: Received ApiVersionResponse (v3, 358 bytes, CorrId 1, rtt 1001.50ms)
%7|1617778134.518|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9092/bootstrap]: 192.0.1.2:9092/bootstrap: Sent MetadataRequest (v4, 32 bytes @ 0, CorrId 2)
%7|1617778135.511|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9092/bootstrap]: 192.0.1.2:9092/bootstrap: Received MetadataResponse (v4, 242 bytes, CorrId 2, rtt 993.05ms)
%7|1617778135.512|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9092/bootstrap]: 192.0.1.2:9092/bootstrap: Sent MetadataRequest (v4, 32 bytes @ 0, CorrId 3)
%7|1617778135.519|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9092/bootstrap]: 192.0.1.2:9092/bootstrap: Received MetadataResponse (v4, 242 bytes, CorrId 3, rtt 7.61ms)
%7|1617778135.539|CONNECTED|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Connected (#1)
%7|1617778135.539|FEATURE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Updated enabled protocol features +ApiVersion to ApiVersion
%7|1617778135.540|CONNECTED|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Connected (#1)
%7|1617778135.540|FEATURE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Updated enabled protocol features +ApiVersion to ApiVersion
%7|1617778135.540|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ApiVersionRequest (v3, 40 bytes @ 0, CorrId 1)
%7|1617778135.540|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ApiVersionRequest (v3, 40 bytes @ 0, CorrId 1)
%7|1617778135.541|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Received ApiVersionResponse (v3, 358 bytes, CorrId 1, rtt 1.15ms)
%7|1617778135.543|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Received ApiVersionResponse (v3, 358 bytes, CorrId 1, rtt 2.13ms)
%7|1617778135.710|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778135.714|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778135.717|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778135.720|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778135.725|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+232117/316048 bytes, CorrId 2)
%7|1617778135.725|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 2)
%7|1617778135.729|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778135.732|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778135.734|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 4)
%7|1617778136.705|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 110028+122089/316048 bytes, CorrId 2)
%7|1617778136.706|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 4)
%7|1617778136.707|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 2)
%7|1617778136.707|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778136.707|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 2)
%7|1617778136.707|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778136.715|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778136.716|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778136.717|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778136.718|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778136.720|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 3)
%7|1617778137.706|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 110028+122089/316048 bytes, CorrId 3)
%7|1617778137.709|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 4)
%7|1617778137.709|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778137.711|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 3)
%7|1617778137.712|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 110028+122089/316048 bytes, CorrId 3)
%7|1617778137.717|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778137.719|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778137.721|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 5)
%7|1617778138.709|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 3)
%7|1617778138.709|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778138.711|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 5)
%7|1617778138.712|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 3)
%7|1617778138.712|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778138.718|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778138.720|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778138.721|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778138.721|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 4)
%7|1617778138.723|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778138.725|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 4)
%7|1617778139.720|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 316048 bytes @ 68632, CorrId 4)
%7|1617778139.720|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778139.723|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 5)
%7|1617778139.723|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778139.725|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 316048 bytes @ 110028, CorrId 4)
%7|1617778139.725|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778139.746|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778139.748|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778139.755|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778139.757|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778139.771|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778139.774|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778139.775|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+232117/316048 bytes, CorrId 6)
%7|1617778139.776|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 5)
%7|1617778139.777|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 5)
%7|1617778139.786|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 6)
%7|1617778139.786|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778139.786|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 5)
%7|1617778139.793|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778139.795|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778139.799|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 316048 bytes @ 0, CorrId 7)
%7|1617778139.799|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778139.807|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778139.809|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778139.811|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 8)
%7|1617778140.843|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 5)
%7|1617778140.843|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778140.844|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 8)
%7|1617778140.844|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 5)
%7|1617778140.863|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778140.873|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778141.945|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 8)
%7|1617778141.946|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 6)
%7|1617778141.946|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778141.947|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 5)
%7|1617778141.947|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778142.208|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778142.220|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778142.222|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 6)
%7|1617778142.225|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778142.227|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778142.228|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 9)
%7|1617778143.221|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 68632+0/316048 bytes, CorrId 6)
%7|1617778143.218|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 68632+0/316048 bytes, CorrId 9)
%7|1617778143.274|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 68632+0/316048 bytes, CorrId 6)
%7|1617778143.276|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 6)
%7|1617778144.358|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 9)
%7|1617778144.422|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 6)
%7|1617778144.422|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778144.422|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 6)
%7|1617778144.433|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778144.439|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778144.446|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 7)
%7|1617778145.395|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 9)
%7|1617778145.395|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778145.396|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 3891+0/316048 bytes, CorrId 7)
%7|1617778145.397|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 6)
%7|1617778145.398|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778145.408|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778145.411|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778145.411|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778145.413|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 10)
%7|1617778145.413|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778145.414|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 7)
%7|1617778146.318|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 316048 bytes @ 110028, CorrId 7)
%7|1617778146.319|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 68632+163485/316048 bytes, CorrId 10)
%7|1617778146.320|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778146.328|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 10)
%7|1617778146.328|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778146.331|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 68632+0/316048 bytes, CorrId 7)
%7|1617778146.338|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778146.342|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778146.343|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778146.344|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 8)
%7|1617778146.349|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778146.349|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 11)
%7|1617778147.345|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 68632+0/316048 bytes, CorrId 8)
%7|1617778147.346|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 7)
%7|1617778147.352|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 8)
%7|1617778147.353|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 2316+229801/316048 bytes, CorrId 11)
%7|1617778147.354|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 7)
%7|1617778147.354|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778147.362|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778147.364|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778147.482|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 8)
%7|1617778147.483|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 316048 bytes @ 110028, CorrId 8)
%7|1617778147.484|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778147.494|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778147.496|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778147.530|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+232117/316048 bytes, CorrId 9)
%7|1617778147.532|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 9)
%7|1617778147.532|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778147.543|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778147.546|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778147.549|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 10)
%7|1617778148.325|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 8)
%7|1617778148.325|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778148.335|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778148.337|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778148.341|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+232117/316048 bytes, CorrId 9)
%7|1617778148.343|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 11)
%7|1617778148.343|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778148.346|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 68632+163485/316048 bytes, CorrId 10)
%7|1617778148.350|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778148.352|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778148.355|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 12)
%7|1617778149.326|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 9)
%7|1617778149.326|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778149.333|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778149.337|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778149.345|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 12)
%7|1617778149.400|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 10)
%7|1617778149.400|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778149.405|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+232117/316048 bytes, CorrId 10)
%7|1617778149.407|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778149.409|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778149.413|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 11)
%7|1617778149.413|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 11)
%7|1617778150.327|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 10)
%7|1617778150.327|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778150.335|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778150.337|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778150.340|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 11)
%7|1617778150.341|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 11)
%7|1617778150.342|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 11)
%7|1617778150.342|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778150.346|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 12)
%7|1617778150.346|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778150.350|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778150.351|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 11)
%7|1617778150.351|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778150.354|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778150.356|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778150.358|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778150.361|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778150.361|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 13)
%7|1617778150.365|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778150.368|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 12)
%7|1617778150.377|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+232117/316048 bytes, CorrId 12)
%7|1617778151.329|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 316048 bytes @ 165960, CorrId 12)
%7|1617778151.330|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778151.342|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778151.351|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 68632+0/316048 bytes, CorrId 13)
%7|1617778151.358|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 13)
%7|1617778151.351|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778151.363|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 13)
%7|1617778151.364|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 12)
%7|1617778151.364|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778151.378|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778151.382|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778151.382|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 13)
%7|1617778152.330|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 68632+0/316048 bytes, CorrId 13)
%7|1617778152.352|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 13)
%7|1617778152.352|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778152.358|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 2946+0/316048 bytes, CorrId 13)
%7|1617778152.361|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778152.363|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778152.364|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 14)
%7|1617778153.331|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 13)
%7|1617778153.355|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 68632+0/316048 bytes, CorrId 14)
%7|1617778153.360|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 68632+0/316048 bytes, CorrId 13)
%7|1617778154.333|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 13)
%7|1617778154.334|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778154.343|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778154.346|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778154.347|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 14)
%7|1617778154.355|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 14)
%7|1617778154.361|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 13)
%7|1617778155.335|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 68632+0/316048 bytes, CorrId 14)
%7|1617778155.335|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 14)
%7|1617778155.336|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 14)
%7|1617778155.336|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778155.343|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778155.347|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778155.348|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 15)
%7|1617778155.356|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 14)
%7|1617778155.356|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778155.365|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 13)
%7|1617778155.365|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778155.366|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778155.369|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778155.370|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 15)
%7|1617778155.379|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778155.382|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778155.386|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 14)
%7|1617778156.337|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 110028+122089/316048 bytes, CorrId 15)
%7|1617778156.358|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 110028+122089/316048 bytes, CorrId 15)
%7|1617778156.366|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 110028+122089/316048 bytes, CorrId 14)
%7|1617778157.339|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 15)
%7|1617778157.340|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778157.349|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778157.351|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778157.353|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 16)
%7|1617778157.365|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 15)
%7|1617778157.365|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778157.370|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 14)
%7|1617778157.371|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778157.375|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778157.378|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778157.382|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778157.384|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778157.386|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+232117/316048 bytes, CorrId 16)
%7|1617778157.388|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 15)
%7|1617778157.390|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 16)
%7|1617778157.390|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778157.399|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778157.408|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778157.412|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 17)
%7|1617778157.413|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 316048 bytes @ 110028, CorrId 17)
%7|1617778157.413|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778157.422|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778157.425|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778157.430|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+232117/316048 bytes, CorrId 18)
%7|1617778158.342|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 68632+0/316048 bytes, CorrId 16)
%7|1617778158.343|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 16)
%7|1617778158.365|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 18)
%7|1617778158.365|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778158.372|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 15)
%7|1617778158.373|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778158.376|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778158.378|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 19)
%7|1617778159.343|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 16)
%7|1617778159.343|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778159.352|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778159.357|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778159.363|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+232117/316048 bytes, CorrId 17)
%7|1617778159.386|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 110028+122089/316048 bytes, CorrId 19)
%7|1617778159.394|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 15)
%7|1617778159.394|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778159.405|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778159.408|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778159.413|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 316048 bytes @ 0, CorrId 16)
%7|1617778159.413|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778159.419|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778159.430|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778159.431|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 17)
%7|1617778159.433|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 68632+163485/316048 bytes, CorrId 17)
%7|1617778160.345|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 17)
%7|1617778160.345|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778160.353|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778160.355|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778160.357|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 18)
%7|1617778160.358|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 18)
%7|1617778160.391|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 19)
%7|1617778160.391|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778160.399|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 17)
%7|1617778160.399|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778160.421|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778160.425|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778160.427|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778160.430|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778160.434|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 18)
%7|1617778160.436|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 20)
%7|1617778160.436|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 110028+122089/316048 bytes, CorrId 18)
%7|1617778161.347|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 18)
%7|1617778161.347|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778161.354|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778161.356|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778161.358|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 19)
%7|1617778161.393|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 20)
%7|1617778161.396|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 18)
%7|1617778161.396|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778161.412|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778161.415|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778161.416|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 19)
%7|1617778162.348|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 68632+0/316048 bytes, CorrId 19)
%7|1617778162.394|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 20)
%7|1617778162.394|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778162.397|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 68632+0/316048 bytes, CorrId 19)
%7|1617778162.403|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778162.405|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778162.429|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 316048 bytes @ 0, CorrId 21)
%7|1617778162.429|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778162.438|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778162.441|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778162.448|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 316048 bytes @ 0, CorrId 22)
%7|1617778162.448|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778162.457|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778162.459|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778162.468|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+232117/316048 bytes, CorrId 23)
%7|1617778163.350|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 19)
%7|1617778163.395|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 23)
%7|1617778163.395|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778163.399|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 19)
%7|1617778163.402|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778163.405|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778163.406|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 24)
%7|1617778163.407|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 110028+122089/316048 bytes, CorrId 24)
%7|1617778164.355|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 19)
%7|1617778164.356|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778164.366|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778164.368|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778164.370|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 20)
%7|1617778164.398|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 24)
%7|1617778164.399|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778164.405|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 19)
%7|1617778164.405|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778164.414|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778164.417|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778164.417|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778164.421|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778165.354|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 68632+0/316048 bytes, CorrId 20)
%7|1617778165.398|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 25)
%7|1617778165.404|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 20)
%7|1617778166.358|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 316048 bytes @ 165960, CorrId 20)
%7|1617778166.358|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778166.371|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778166.373|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778166.374|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 21)
%7|1617778166.400|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 68632+0/316048 bytes, CorrId 25)
%7|1617778166.404|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 68632+0/316048 bytes, CorrId 20)
%7|1617778167.360|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 68632+163485/316048 bytes, CorrId 21)
%7|1617778167.361|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 21)
%7|1617778167.361|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778167.369|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778167.372|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778167.373|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 22)
%7|1617778167.401|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 25)
%7|1617778167.406|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 20)
%7|1617778167.407|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 20)
%7|1617778167.407|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778167.414|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778167.416|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778167.418|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 21)
%7|1617778168.360|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 68632+0/316048 bytes, CorrId 22)
%7|1617778168.403|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 25)
%7|1617778168.404|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778168.409|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 68632+0/316048 bytes, CorrId 21)
%7|1617778168.411|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778168.414|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778168.418|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+232117/316048 bytes, CorrId 26)
%7|1617778169.360|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 22)
%7|1617778169.361|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 22)
%7|1617778169.361|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778169.369|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778169.372|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778169.375|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 23)
%7|1617778169.405|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 26)
%7|1617778169.405|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778169.412|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778169.415|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 21)
%7|1617778169.415|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778169.431|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 21)
%7|1617778169.431|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778169.433|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+232117/316048 bytes, CorrId 27)
%7|1617778169.439|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778169.442|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778169.445|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+232117/316048 bytes, CorrId 22)
%7|1617778169.446|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 22)
%7|1617778169.446|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778169.453|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778169.455|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778169.458|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 23)
%7|1617778170.375|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 23)
%7|1617778170.406|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 27)
%7|1617778170.406|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778170.415|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778170.418|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778170.419|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 316048 bytes @ 165960, CorrId 23)
%7|1617778170.419|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778170.421|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 28)
%7|1617778170.433|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778170.436|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778170.438|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 24)
%7|1617778171.377|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 23)
%7|1617778171.377|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778171.385|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778171.388|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778171.388|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 24)
%7|1617778171.409|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 110028+0/316048 bytes, CorrId 28)
%7|1617778171.417|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 110028+122089/316048 bytes, CorrId 24)
%7|1617778171.418|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 24)
%7|1617778171.418|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778171.426|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778171.428|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778171.430|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 25)
%7|1617778172.378|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 3261+0/316048 bytes, CorrId 24)
%7|1617778172.380|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 24)
%7|1617778172.411|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 316048 bytes @ 249700, CorrId 28)
%7|1617778172.412|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778172.419|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 110028+122089/316048 bytes, CorrId 25)
%7|1617778172.420|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 25)
%7|1617778172.420|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778172.423|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778172.425|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778172.428|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778172.430|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778172.433|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 26)
%7|1617778172.437|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+232117/316048 bytes, CorrId 29)
%7|1617778173.378|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 24)
%7|1617778173.378|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778173.388|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778173.390|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778173.391|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 25)
%7|1617778173.413|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 29)
%7|1617778173.413|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778173.420|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 26)
%7|1617778173.421|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 26)
%7|1617778173.421|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778173.422|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778173.424|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778173.426|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 30)
%7|1617778173.429|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778173.431|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778173.433|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 27)
%7|1617778174.380|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 2631+0/316048 bytes, CorrId 25)
%7|1617778174.416|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 110028+122089/316048 bytes, CorrId 30)
%7|1617778174.422|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 68632+163485/316048 bytes, CorrId 27)
%7|1617778174.423|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 27)
%7|1617778174.423|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778174.432|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778174.434|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778174.435|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 28)
%7|1617778175.383|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 68632+0/316048 bytes, CorrId 25)
%7|1617778175.415|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 30)
%7|1617778175.415|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778175.424|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 68632+0/316048 bytes, CorrId 28)
%7|1617778175.425|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778175.428|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778175.429|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 31)
%7|1617778176.382|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 25)
%7|1617778176.384|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 25)
%7|1617778176.384|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778176.393|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778176.395|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778176.396|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 26)
%7|1617778176.416|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 68632+0/316048 bytes, CorrId 31)
%7|1617778176.426|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 28)
%7|1617778177.384|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 68632+0/316048 bytes, CorrId 26)
%7|1617778177.441|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 31)
%7|1617778177.441|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 28)
%7|1617778177.441|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778177.464|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778177.466|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778177.468|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 29)
%7|1617778178.385|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 26)
%7|1617778178.443|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 31)
%7|1617778178.443|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778178.444|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 68632+163485/316048 bytes, CorrId 29)
%7|1617778178.451|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778178.454|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778178.456|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+232117/316048 bytes, CorrId 32)
%7|1617778178.457|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 32)
%7|1617778178.457|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778178.465|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778178.467|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778178.470|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 33)
%7|1617778178.471|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 33)
%7|1617778179.388|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 26)
%7|1617778179.388|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778179.396|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778179.400|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778179.405|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+232117/316048 bytes, CorrId 27)
%7|1617778179.444|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 33)
%7|1617778179.444|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778179.449|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 29)
%7|1617778179.449|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778179.454|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778179.459|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778179.459|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778179.467|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778179.490|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 30)
%7|1617778179.508|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+232117/316048 bytes, CorrId 34)
%7|1617778180.390|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 27)
%7|1617778180.390|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778180.399|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778180.401|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778180.404|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+232117/316048 bytes, CorrId 28)
%7|1617778180.444|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 34)
%7|1617778180.444|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778180.450|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 68632+0/316048 bytes, CorrId 30)
%7|1617778180.454|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778180.457|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778180.459|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 35)
%7|1617778181.393|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 28)
%7|1617778181.394|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778181.412|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778181.414|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778181.416|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 29)
%7|1617778181.446|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 110028+122089/316048 bytes, CorrId 35)
%7|1617778181.453|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 30)
%7|1617778182.393|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 68632+163485/316048 bytes, CorrId 29)
%7|1617778182.394|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 29)
%7|1617778182.394|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778182.402|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778182.404|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778182.405|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 30)
%7|1617778182.452|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 35)
%7|1617778182.453|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778182.459|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 30)
%7|1617778182.460|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778182.466|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778182.469|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778182.470|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778182.472|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778183.394|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 68632+0/316048 bytes, CorrId 30)
%7|1617778183.468|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 36)
%7|1617778183.473|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 31)
%7|1617778184.395|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 30)
%7|1617778184.396|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 30)
%7|1617778184.396|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778184.404|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778184.406|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778184.408|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 31)
%7|1617778184.469|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 68632+0/316048 bytes, CorrId 31)
%7|1617778184.473|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 69567+0/316048 bytes, CorrId 36)
%7|1617778185.397|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 68632+0/316048 bytes, CorrId 31)
%7|1617778185.469|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 31)
%7|1617778185.472|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 36)
%7|1617778186.399|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 316048 bytes @ 165960, CorrId 31)
%7|1617778186.399|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778186.408|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778186.410|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778186.411|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 32)
%7|1617778186.472|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 31)
%7|1617778186.472|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778186.476|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 36)
%7|1617778186.476|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778186.479|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778186.481|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: Produce MessageSet with 334 message(s) (105541 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778186.482|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778187.400|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 68632+0/316048 bytes, CorrId 32)
%7|1617778187.400|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 32)
%7|1617778187.475|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/316048 bytes, CorrId 32)
%7|1617778187.485|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 68632+0/316048 bytes, CorrId 32)
%7|1617778187.492|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 105592 bytes @ 0, CorrId 37)
%7|1617778187.492|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [0]: MessageSet with 334 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778188.401|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 32)
%7|1617778188.401|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778188.409|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778188.411|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778188.414|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+232117/316048 bytes, CorrId 33)
%7|1617778188.476|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 165960+66157/316048 bytes, CorrId 32)
%7|1617778188.477|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 32)
%7|1617778188.477|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778188.485|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778188.487|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778188.491|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+232117/316048 bytes, CorrId 33)
%7|1617778189.404|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 33)
%7|1617778189.404|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778189.414|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778189.418|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778189.429|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+232117/316048 bytes, CorrId 34)
%7|1617778189.432|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 34)
%7|1617778189.433|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778189.437|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: Produce MessageSet with 333 message(s) (105225 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778189.440|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 105276 bytes @ 0, CorrId 35)
%7|1617778189.440|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [2]: MessageSet with 333 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778189.478|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 33)
%7|1617778189.478|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778189.484|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: No more space in current MessageSet (1000 message(s), 316048 bytes)
%7|1617778189.487|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: Produce MessageSet with 1000 message(s) (315997 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778189.491|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+232117/316048 bytes, CorrId 34)
%7|1617778189.492|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 316048 bytes @ 232117, CorrId 34)
%7|1617778189.492|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: MessageSet with 1000 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617778189.496|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: Produce MessageSet with 333 message(s) (105225 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617778189.505|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 105276 bytes @ 0, CorrId 35)
%7|1617778189.505|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [1]: MessageSet with 333 message(s) (MsgId 0, BaseSeq -1) delivered