%7|1617902829.444|CONF|rdkafka#producer-1| [thrd::0/internal]: Client configuration:
%7|1617902829.444|CONF|rdkafka#producer-1| [thrd::0/internal]:   client.software.version = 1.6.1
%7|1617902829.444|CONF|rdkafka#producer-1| [thrd::0/internal]:   metadata.broker.list = 192.0.1.2:9092
%7|1617902829.444|CONF|rdkafka#producer-1| [thrd::0/internal]:   debug = msg,protocol,conf
%7|1617902829.444|CONF|rdkafka#producer-1| [thrd::0/internal]:   default_topic_conf = 0x5000101b50
%7|1617902829.444|CONF|rdkafka#producer-1| [thrd::0/internal]:   queue.buffering.max.ms = 100
%7|1617902829.445|CONF|rdkafka#producer-1| [thrd::0/internal]:   delivery.report.only.error = true
%7|1617902829.445|CONF|rdkafka#producer-1| [thrd:192.0.1.2:9092/bootstrap]: Default topic configuration:
%7|1617902829.445|CONF|rdkafka#producer-1| [thrd:192.0.1.2:9092/bootstrap]:   request.required.acks = 1
%7|1617902829.449|CONF|rdkafka#producer-1| [thrd:192.0.1.2:9092/bootstrap]: Topic "kpis" configuration (user-supplied):
%7|1617902829.449|CONF|rdkafka#producer-1| [thrd:192.0.1.2:9092/bootstrap]:   request.required.acks = 1

%7|1617902830.448|CONNECTED|rdkafka#producer-1| [thrd:192.0.1.2:9092/bootstrap]: 192.0.1.2:9092/bootstrap: Connected (#1)
%7|1617902830.448|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|1617902830.449|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|1617902831.450|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 1000.89ms)
%7|1617902831.451|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|1617902832.437|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9092/bootstrap]: 192.0.1.2:9092/bootstrap: Received MetadataResponse (v4, 194 bytes, CorrId 2, rtt 985.27ms)
%7|1617902832.437|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|1617902832.457|CONNECTED|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Connected (#1)
%7|1617902832.457|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|1617902832.458|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|1617902832.458|CONNECTED|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Connected (#1)
%7|1617902832.458|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|1617902832.458|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|1617902832.460|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 2.26ms)
%7|1617902832.460|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.24ms)
%7|1617902832.550|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Received MetadataResponse (v4, 194 bytes, CorrId 3, rtt 112.28ms)
%7|1617902832.592|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [2]: No more space in current MessageSet (3183 message(s), 999910 bytes)
%7|1617902832.597|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [0]: No more space in current MessageSet (3183 message(s), 999878 bytes)
%7|1617902832.602|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [1]: No more space in current MessageSet (3183 message(s), 999878 bytes)
%7|1617902832.606|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [2]: Produce MessageSet with 3183 message(s) (999859 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617902832.611|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [0]: Produce MessageSet with 3183 message(s) (999827 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617902832.616|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [1]: Produce MessageSet with 3183 message(s) (999827 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617902832.622|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/999910 bytes, CorrId 2)
%7|1617902832.630|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+0/999878 bytes, CorrId 2)
%7|1617902832.639|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+0/999878 bytes, CorrId 4)
Debug: Start time - 2021-04-08 13:27:09
%7|1617902833.549|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 170514+70557/999910 bytes, CorrId 2)
%7|1617902833.552|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 155187+65818/999878 bytes, CorrId 2)
%7|1617902833.556|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 137601+70223/999878 bytes, CorrId 4)
%7|1617902834.552|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 241071+93211/999910 bytes, CorrId 2)
%7|1617902834.554|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 221005+77734/999878 bytes, CorrId 2)
%7|1617902834.558|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 207824+78365/999878 bytes, CorrId 4)
%7|1617902835.554|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 334282+65536/999910 bytes, CorrId 2)
%7|1617902835.555|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 399818+137681/999910 bytes, CorrId 2)
%7|1617902835.556|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 298739+116601/999878 bytes, CorrId 2)
%7|1617902835.557|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 415340+177931/999878 bytes, CorrId 2)
%7|1617902835.558|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 593271+65536/999878 bytes, CorrId 2)
%7|1617902835.558|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 286189+110924/999878 bytes, CorrId 4)
%7|1617902836.555|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 537499+65536/999910 bytes, CorrId 2)
%7|1617902836.556|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 658807+65536/999878 bytes, CorrId 2)
%7|1617902836.561|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 397113+65536/999878 bytes, CorrId 4)
%7|1617902836.561|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 462649+102962/999878 bytes, CorrId 4)
%7|1617902837.557|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 603035+75760/999910 bytes, CorrId 2)
%7|1617902837.557|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 678795+65536/999910 bytes, CorrId 2)
%7|1617902837.558|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 724343+65536/999878 bytes, CorrId 2)
%7|1617902837.559|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 789879+69658/999878 bytes, CorrId 2)
%7|1617902837.559|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 859537+65536/999878 bytes, CorrId 2)
%7|1617902837.559|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 925073+65536/999878 bytes, CorrId 2)
%7|1617902837.559|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 999878 bytes @ 990609, CorrId 2)
%7|1617902837.561|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 565611+65536/999878 bytes, CorrId 4)
%7|1617902837.584|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [0]: No more space in current MessageSet (3183 message(s), 999929 bytes)
%7|1617902837.590|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [0]: Produce MessageSet with 3183 message(s) (999878 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617902837.591|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Received ProduceResponse (v7, 48 bytes, CorrId 2, rtt 31.37ms)
%7|1617902837.591|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [0]: MessageSet with 3183 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617902837.602|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+242312/999929 bytes, CorrId 3)
%7|1617902837.603|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 242312+92278/999929 bytes, CorrId 3)
%7|1617902837.603|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 334590+65536/999929 bytes, CorrId 3)
%7|1617902838.558|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 744331+65536/999910 bytes, CorrId 2)
%7|1617902838.560|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 400126+74706/999929 bytes, CorrId 3)
%7|1617902838.563|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 631147+65536/999878 bytes, CorrId 4)
%7|1617902839.560|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 809867+65536/999910 bytes, CorrId 2)
%7|1617902839.561|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 875403+113632/999910 bytes, CorrId 2)
%7|1617902839.561|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 999910 bytes @ 989035, CorrId 2)
%7|1617902839.565|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 474832+65536/999929 bytes, CorrId 3)
%7|1617902839.570|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 696683+121971/999878 bytes, CorrId 4)
%7|1617902839.587|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [2]: No more space in current MessageSet (3183 message(s), 999889 bytes)
%7|1617902839.598|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [2]: Produce MessageSet with 3183 message(s) (999838 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617902839.599|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Received ProduceResponse (v7, 48 bytes, CorrId 2, rtt 37.86ms)
%7|1617902839.600|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [2]: MessageSet with 3183 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617902839.630|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+289010/999889 bytes, CorrId 3)
%7|1617902839.632|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 289010+179975/999889 bytes, CorrId 3)
%7|1617902839.635|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 468985+172558/999889 bytes, CorrId 3)
%7|1617902839.639|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 641543+65536/999889 bytes, CorrId 3)
%7|1617902839.644|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 707079+130771/999889 bytes, CorrId 3)
%7|1617902839.645|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 837850+65536/999889 bytes, CorrId 3)
%7|1617902839.645|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 903386+65536/999889 bytes, CorrId 3)
%7|1617902840.561|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 999889 bytes @ 968922, CorrId 3)
%7|1617902840.569|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 540368+65536/999929 bytes, CorrId 3)
%7|1617902840.570|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 818654+65536/999878 bytes, CorrId 4)
%7|1617902840.581|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [2]: No more space in current MessageSet (3181 message(s), 999862 bytes)
%7|1617902840.587|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [2]: Produce MessageSet with 3181 message(s) (999811 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617902840.587|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Received ProduceResponse (v7, 48 bytes, CorrId 3, rtt 26.40ms)
%7|1617902840.588|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [2]: MessageSet with 3183 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617902840.596|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/999862 bytes, CorrId 4)
%7|1617902841.564|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 89863+116755/999862 bytes, CorrId 4)
%7|1617902841.566|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 206618+72622/999862 bytes, CorrId 4)
%7|1617902841.570|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 605904+74477/999929 bytes, CorrId 3)
%7|1617902841.572|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 884190+65536/999878 bytes, CorrId 4)
%7|1617902842.566|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 279240+112847/999862 bytes, CorrId 4)
%7|1617902842.567|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 392087+65536/999862 bytes, CorrId 4)
%7|1617902842.572|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 680381+65536/999929 bytes, CorrId 3)
%7|1617902842.573|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 999878 bytes @ 949726, CorrId 4)
%7|1617902842.573|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 745917+131072/999929 bytes, CorrId 3)
%7|1617902842.574|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 876989+117422/999929 bytes, CorrId 3)
%7|1617902842.574|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 999929 bytes @ 994411, CorrId 3)
%7|1617902842.593|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [1]: No more space in current MessageSet (3183 message(s), 999906 bytes)
%7|1617902842.599|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [0]: No more space in current MessageSet (3181 message(s), 999876 bytes)
%7|1617902842.600|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [1]: Produce MessageSet with 3183 message(s) (999855 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617902842.600|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Received ProduceResponse (v7, 48 bytes, CorrId 4, rtt 27.32ms)
%7|1617902842.600|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [1]: MessageSet with 3183 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617902842.605|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [0]: Produce MessageSet with 3181 message(s) (999825 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617902842.606|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Received ProduceResponse (v7, 48 bytes, CorrId 3, rtt 31.09ms)
%7|1617902842.606|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [0]: MessageSet with 3183 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617902842.617|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+0/999876 bytes, CorrId 4)
%7|1617902842.618|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 140135+72443/999876 bytes, CorrId 4)
%7|1617902842.619|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+224445/999906 bytes, CorrId 5)
%7|1617902842.620|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 212578+79205/999876 bytes, CorrId 4)
%7|1617902842.620|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 224445+81263/999906 bytes, CorrId 5)
%7|1617902842.621|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 305708+120692/999906 bytes, CorrId 5)
%7|1617902842.622|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 426400+180432/999906 bytes, CorrId 5)
%7|1617902842.622|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 606832+65536/999906 bytes, CorrId 5)
%7|1617902842.622|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 672368+65536/999906 bytes, CorrId 5)
%7|1617902842.622|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 737904+65536/999906 bytes, CorrId 5)
%7|1617902843.566|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 457623+100744/999862 bytes, CorrId 4)
%7|1617902843.574|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 291783+118519/999876 bytes, CorrId 4)
%7|1617902843.575|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 803440+80959/999906 bytes, CorrId 5)
%7|1617902844.568|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 558367+65536/999862 bytes, CorrId 4)
%7|1617902844.571|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 623903+186865/999862 bytes, CorrId 4)
%7|1617902844.575|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 410302+65536/999876 bytes, CorrId 4)
%7|1617902844.576|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 475838+109542/999876 bytes, CorrId 4)
%7|1617902844.576|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 884399+65536/999906 bytes, CorrId 5)
%7|1617902845.570|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 810768+65536/999862 bytes, CorrId 4)
%7|1617902845.570|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 876304+65536/999862 bytes, CorrId 4)
%7|1617902845.576|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 585380+65536/999876 bytes, CorrId 4)
%7|1617902845.577|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 999906 bytes @ 949935, CorrId 5)
%7|1617902845.596|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [1]: No more space in current MessageSet (3181 message(s), 999862 bytes)
%7|1617902845.603|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [1]: Produce MessageSet with 3181 message(s) (999811 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617902845.604|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+0/999862 bytes, CorrId 6)
%7|1617902846.572|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 999862 bytes @ 941840, CorrId 4)
%7|1617902846.580|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 650916+65536/999876 bytes, CorrId 4)
%7|1617902846.581|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Received ProduceResponse (v7, 48 bytes, CorrId 5, rtt 1003.02ms)
%7|1617902846.581|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [1]: MessageSet with 3183 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617902846.594|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 95211+119915/999862 bytes, CorrId 6)
%7|1617902846.598|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [2]: No more space in current MessageSet (3182 message(s), 999761 bytes)
%7|1617902846.604|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [2]: Produce MessageSet with 3182 message(s) (999710 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617902846.604|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Received ProduceResponse (v7, 48 bytes, CorrId 4, rtt 31.79ms)
%7|1617902846.604|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [2]: MessageSet with 3181 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617902846.614|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/999761 bytes, CorrId 5)
%7|1617902847.576|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 80261+0/999761 bytes, CorrId 5)
%7|1617902847.577|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 196338+71210/999761 bytes, CorrId 5)
%7|1617902847.581|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 215126+75106/999862 bytes, CorrId 6)
%7|1617902847.585|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 716452+134573/999876 bytes, CorrId 4)
%7|1617902848.576|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 267548+103692/999761 bytes, CorrId 5)
%7|1617902848.577|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 371240+65536/999761 bytes, CorrId 5)
%7|1617902848.584|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 290232+115050/999862 bytes, CorrId 6)
%7|1617902848.584|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 405282+65536/999862 bytes, CorrId 6)
%7|1617902848.585|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 851025+65536/999876 bytes, CorrId 4)
%7|1617902849.576|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 436776+88201/999761 bytes, CorrId 5)
%7|1617902849.586|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 470818+106744/999862 bytes, CorrId 6)
%7|1617902849.586|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 577562+65536/999862 bytes, CorrId 6)
%7|1617902849.586|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 916561+65536/999876 bytes, CorrId 4)
%7|1617902849.587|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 643098+65536/999862 bytes, CorrId 6)
%7|1617902849.587|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 999876 bytes @ 982097, CorrId 4)
%7|1617902849.606|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [0]: No more space in current MessageSet (3182 message(s), 999752 bytes)
%7|1617902849.612|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [0]: Produce MessageSet with 3182 message(s) (999701 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617902849.613|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Received ProduceResponse (v7, 48 bytes, CorrId 4, rtt 25.80ms)
%7|1617902849.613|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [0]: MessageSet with 3181 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617902849.624|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+0/999752 bytes, CorrId 5)
%7|1617902849.625|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 130090+69307/999752 bytes, CorrId 5)
%7|1617902849.625|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 199397+68732/999752 bytes, CorrId 5)
%7|1617902849.626|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 268129+102173/999752 bytes, CorrId 5)
%7|1617902849.626|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 370302+65536/999752 bytes, CorrId 5)
%7|1617902850.579|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 524977+65536/999761 bytes, CorrId 5)
%7|1617902850.587|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 708634+127938/999862 bytes, CorrId 6)
%7|1617902850.588|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 836572+65536/999862 bytes, CorrId 6)
%7|1617902850.588|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 435838+91917/999752 bytes, CorrId 5)
%7|1617902851.580|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 590513+65536/999761 bytes, CorrId 5)
%7|1617902851.581|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 656049+104347/999761 bytes, CorrId 5)
%7|1617902851.588|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 902108+65536/999862 bytes, CorrId 6)
%7|1617902851.589|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 527755+65536/999752 bytes, CorrId 5)
%7|1617902851.590|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 593291+65536/999752 bytes, CorrId 5)
%7|1617902852.582|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 760396+65536/999761 bytes, CorrId 5)
%7|1617902852.589|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 999862 bytes @ 967644, CorrId 6)
%7|1617902852.591|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 658827+100324/999752 bytes, CorrId 5)
%7|1617902852.609|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [1]: No more space in current MessageSet (3182 message(s), 999792 bytes)
%7|1617902852.615|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [1]: Produce MessageSet with 3182 message(s) (999741 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617902852.615|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Received ProduceResponse (v7, 48 bytes, CorrId 6, rtt 26.37ms)
%7|1617902852.615|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [1]: MessageSet with 3181 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617902852.626|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+204120/999792 bytes, CorrId 7)
%7|1617902852.627|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 204120+74091/999792 bytes, CorrId 7)
%7|1617902852.628|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 278211+108138/999792 bytes, CorrId 7)
%7|1617902853.583|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 825932+65536/999761 bytes, CorrId 5)
%7|1617902853.583|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 891468+65536/999761 bytes, CorrId 5)
%7|1617902853.590|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 386349+65536/999792 bytes, CorrId 7)
%7|1617902853.591|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 451885+96998/999792 bytes, CorrId 7)
%7|1617902853.592|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 548883+65536/999792 bytes, CorrId 7)
%7|1617902853.593|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 759151+65536/999752 bytes, CorrId 5)
%7|1617902853.594|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 824687+65536/999752 bytes, CorrId 5)
%7|1617902854.585|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 999761 bytes @ 957004, CorrId 5)
%7|1617902854.591|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 614419+65536/999792 bytes, CorrId 7)
%7|1617902854.595|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 890223+65536/999752 bytes, CorrId 5)
%7|1617902854.605|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [2]: No more space in current MessageSet (3183 message(s), 999913 bytes)
%7|1617902854.611|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [2]: Produce MessageSet with 3183 message(s) (999862 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617902854.612|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Received ProduceResponse (v7, 48 bytes, CorrId 5, rtt 26.73ms)
%7|1617902854.612|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [2]: MessageSet with 3182 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617902854.622|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/999913 bytes, CorrId 6)
%7|1617902855.587|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 96299+121633/999913 bytes, CorrId 6)
%7|1617902855.588|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 217932+77728/999913 bytes, CorrId 6)
%7|1617902855.588|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 295660+115978/999913 bytes, CorrId 6)
%7|1617902855.589|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 411638+176964/999913 bytes, CorrId 6)
%7|1617902855.590|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 588602+65536/999913 bytes, CorrId 6)
%7|1617902855.594|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 679955+116627/999792 bytes, CorrId 7)
%7|1617902855.594|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 796582+65536/999792 bytes, CorrId 7)
%7|1617902855.597|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 999752 bytes @ 955759, CorrId 5)
%7|1617902855.618|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [0]: No more space in current MessageSet (3183 message(s), 999898 bytes)
%7|1617902855.624|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [0]: Produce MessageSet with 3183 message(s) (999847 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617902855.625|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Received ProduceResponse (v7, 48 bytes, CorrId 5, rtt 27.82ms)
%7|1617902855.625|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [0]: MessageSet with 3182 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617902855.637|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+0/999898 bytes, CorrId 6)
%7|1617902855.638|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 155464+151784/999898 bytes, CorrId 6)
%7|1617902855.639|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 307248+123861/999898 bytes, CorrId 6)
%7|1617902856.588|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 654138+65536/999913 bytes, CorrId 6)
%7|1617902856.594|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 719674+201672/999913 bytes, CorrId 6)
%7|1617902856.595|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 862118+65536/999792 bytes, CorrId 7)
%7|1617902856.597|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 921346+65536/999913 bytes, CorrId 6)
%7|1617902856.597|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 999913 bytes @ 986882, CorrId 6)
%7|1617902856.600|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 927654+65536/999792 bytes, CorrId 7)
%7|1617902856.600|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 999792 bytes @ 993190, CorrId 7)
%7|1617902856.603|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 431109+65536/999898 bytes, CorrId 6)
%7|1617902856.609|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 496645+120550/999898 bytes, CorrId 6)
%7|1617902856.609|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 617195+65536/999898 bytes, CorrId 6)
%7|1617902856.609|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 682731+65536/999898 bytes, CorrId 6)
%7|1617902856.621|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [2]: No more space in current MessageSet (3182 message(s), 999708 bytes)
%7|1617902856.623|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [1]: No more space in current MessageSet (3183 message(s), 999897 bytes)
%7|1617902856.629|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [2]: Produce MessageSet with 3182 message(s) (999657 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617902856.629|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Received ProduceResponse (v7, 48 bytes, CorrId 6, rtt 32.19ms)
%7|1617902856.629|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [2]: MessageSet with 3183 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617902856.632|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [1]: Produce MessageSet with 3183 message(s) (999846 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617902856.633|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Received ProduceResponse (v7, 48 bytes, CorrId 7, rtt 32.41ms)
%7|1617902856.633|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [1]: MessageSet with 3182 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617902856.641|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+208470/999708 bytes, CorrId 7)
%7|1617902856.642|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 208470+76545/999708 bytes, CorrId 7)
%7|1617902856.647|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+216934/999897 bytes, CorrId 8)
%7|1617902857.590|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 285015+110655/999708 bytes, CorrId 7)
%7|1617902857.591|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 395670+65536/999708 bytes, CorrId 7)
%7|1617902857.596|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 216934+79620/999897 bytes, CorrId 8)
%7|1617902857.597|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 296554+118817/999897 bytes, CorrId 8)
%7|1617902857.606|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 748267+65536/999898 bytes, CorrId 6)
%7|1617902858.593|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 461206+100424/999708 bytes, CorrId 7)
%7|1617902858.593|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 561630+65536/999708 bytes, CorrId 7)
%7|1617902858.598|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 415371+65536/999897 bytes, CorrId 8)
%7|1617902858.608|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 813803+82226/999898 bytes, CorrId 6)
%7|1617902858.608|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 896029+65536/999898 bytes, CorrId 6)
%7|1617902859.595|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 627166+65536/999708 bytes, CorrId 7)
%7|1617902859.600|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 480907+112370/999897 bytes, CorrId 8)
%7|1617902859.601|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 593277+65536/999897 bytes, CorrId 8)
%7|1617902859.609|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 999898 bytes @ 961565, CorrId 6)
%7|1617902859.629|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [0]: No more space in current MessageSet (3182 message(s), 999652 bytes)
%7|1617902859.636|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [0]: Produce MessageSet with 3182 message(s) (999601 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617902859.637|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Received ProduceResponse (v7, 48 bytes, CorrId 6, rtt 27.33ms)
%7|1617902859.637|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [0]: MessageSet with 3183 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617902859.649|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+0/999652 bytes, CorrId 7)
%7|1617902860.596|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 692702+116975/999708 bytes, CorrId 7)
%7|1617902860.596|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 809677+65536/999708 bytes, CorrId 7)
%7|1617902860.600|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 658813+65536/999897 bytes, CorrId 8)
%7|1617902860.611|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 86223+124436/999652 bytes, CorrId 7)
%7|1617902861.597|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 875213+65536/999708 bytes, CorrId 7)
%7|1617902861.598|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 999708 bytes @ 940749, CorrId 7)
%7|1617902861.602|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 724349+65536/999897 bytes, CorrId 8)
%7|1617902861.603|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 789885+69646/999897 bytes, CorrId 8)
%7|1617902861.611|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 210659+74378/999652 bytes, CorrId 7)
%7|1617902861.620|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [2]: No more space in current MessageSet (3183 message(s), 999931 bytes)
%7|1617902861.626|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [2]: Produce MessageSet with 3183 message(s) (999880 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617902861.627|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Received ProduceResponse (v7, 48 bytes, CorrId 7, rtt 28.89ms)
%7|1617902861.627|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [2]: MessageSet with 3182 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617902861.637|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/999931 bytes, CorrId 8)
%7|1617902862.600|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 150132+72426/999931 bytes, CorrId 8)
%7|1617902862.604|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 859531+65536/999897 bytes, CorrId 8)
%7|1617902862.614|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 285037+176458/999652 bytes, CorrId 7)
%7|1617902863.601|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 222558+79986/999931 bytes, CorrId 8)
%7|1617902863.603|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 302544+124179/999931 bytes, CorrId 8)
%7|1617902863.605|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 925067+65536/999897 bytes, CorrId 8)
%7|1617902863.606|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 999897 bytes @ 990603, CorrId 8)
%7|1617902863.615|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 461495+103293/999652 bytes, CorrId 7)
%7|1617902863.630|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [1]: No more space in current MessageSet (3182 message(s), 999652 bytes)
%7|1617902863.636|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [1]: Produce MessageSet with 3182 message(s) (999601 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617902863.636|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Received ProduceResponse (v7, 48 bytes, CorrId 8, rtt 29.52ms)
%7|1617902863.636|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [1]: MessageSet with 3183 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617902863.647|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+0/999652 bytes, CorrId 9)
%7|1617902863.647|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 149841+69293/999652 bytes, CorrId 9)
%7|1617902863.648|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 219134+82538/999652 bytes, CorrId 9)
%7|1617902863.649|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 301672+122572/999652 bytes, CorrId 9)
%7|1617902863.649|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 424244+65536/999652 bytes, CorrId 9)
%7|1617902864.602|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 426723+65536/999931 bytes, CorrId 8)
%7|1617902864.607|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 489780+117708/999652 bytes, CorrId 9)
%7|1617902864.615|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 564788+65536/999652 bytes, CorrId 7)
%7|1617902865.603|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 492259+118659/999931 bytes, CorrId 8)
%7|1617902865.604|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 610918+65536/999931 bytes, CorrId 8)
%7|1617902865.605|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 676454+65536/999931 bytes, CorrId 8)
%7|1617902865.605|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 741990+65536/999931 bytes, CorrId 8)
%7|1617902865.607|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 807526+79701/999931 bytes, CorrId 8)
%7|1617902865.607|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 887227+65536/999931 bytes, CorrId 8)
%7|1617902865.607|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 607488+65536/999652 bytes, CorrId 9)
%7|1617902865.608|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 673024+65536/999652 bytes, CorrId 9)
%7|1617902865.608|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 738560+65536/999652 bytes, CorrId 9)
%7|1617902865.616|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 630324+65536/999652 bytes, CorrId 7)
%7|1617902866.605|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 999931 bytes @ 952763, CorrId 8)
%7|1617902866.609|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 804096+80665/999652 bytes, CorrId 9)
%7|1617902866.610|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 884761+65536/999652 bytes, CorrId 9)
%7|1617902866.610|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 999652 bytes @ 950297, CorrId 9)
%7|1617902866.621|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 695860+119789/999652 bytes, CorrId 7)
%7|1617902866.629|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [2]: No more space in current MessageSet (3183 message(s), 999912 bytes)
%7|1617902866.639|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [1]: No more space in current MessageSet (3183 message(s), 999953 bytes)
%7|1617902866.641|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [2]: Produce MessageSet with 3183 message(s) (999861 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617902866.642|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Received ProduceResponse (v7, 48 bytes, CorrId 8, rtt 36.23ms)
%7|1617902866.642|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [2]: MessageSet with 3183 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617902866.649|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [1]: Produce MessageSet with 3183 message(s) (999902 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617902866.651|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Received ProduceResponse (v7, 48 bytes, CorrId 9, rtt 41.12ms)
%7|1617902866.651|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [1]: MessageSet with 3182 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617902866.658|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/999912 bytes, CorrId 9)
%7|1617902866.662|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 115046+132282/999912 bytes, CorrId 9)
%7|1617902866.663|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 247328+93583/999912 bytes, CorrId 9)
%7|1617902866.672|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+0/999953 bytes, CorrId 10)
%7|1617902867.606|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 340911+65536/999912 bytes, CorrId 9)
%7|1617902867.609|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 180875+70524/999953 bytes, CorrId 10)
%7|1617902867.624|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 815649+65536/999652 bytes, CorrId 7)
%7|1617902867.625|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 881185+65536/999652 bytes, CorrId 7)
%7|1617902868.607|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 406447+72462/999912 bytes, CorrId 9)
%7|1617902868.607|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 478909+65536/999912 bytes, CorrId 9)
%7|1617902868.611|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 251399+97411/999953 bytes, CorrId 10)
%7|1617902868.611|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 348810+65536/999953 bytes, CorrId 10)
%7|1617902868.626|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 999652 bytes @ 946721, CorrId 7)
%7|1617902868.643|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [0]: No more space in current MessageSet (3182 message(s), 999660 bytes)
%7|1617902868.650|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [0]: Produce MessageSet with 3182 message(s) (999609 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617902868.650|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Received ProduceResponse (v7, 48 bytes, CorrId 7, rtt 23.87ms)
%7|1617902868.650|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [0]: MessageSet with 3182 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617902868.660|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+211011/999660 bytes, CorrId 8)
%7|1617902869.608|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 544445+65536/999912 bytes, CorrId 9)
%7|1617902869.609|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 609981+79225/999912 bytes, CorrId 9)
%7|1617902869.612|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 414346+80310/999953 bytes, CorrId 10)
%7|1617902869.613|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 494656+65536/999953 bytes, CorrId 10)
%7|1617902869.627|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 211011+73048/999660 bytes, CorrId 8)
%7|1617902870.609|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 689206+65536/999912 bytes, CorrId 9)
%7|1617902870.613|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 560192+65536/999953 bytes, CorrId 10)
%7|1617902870.628|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 284059+113462/999660 bytes, CorrId 8)
%7|1617902871.611|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 754742+65536/999912 bytes, CorrId 9)
%7|1617902871.612|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 820278+65536/999912 bytes, CorrId 9)
%7|1617902871.613|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 999912 bytes @ 885814, CorrId 9)
%7|1617902871.615|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 625728+87394/999953 bytes, CorrId 10)
%7|1617902871.629|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 397521+65536/999660 bytes, CorrId 8)
%7|1617902871.635|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [2]: No more space in current MessageSet (3183 message(s), 999909 bytes)
%7|1617902871.641|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [2]: Produce MessageSet with 3183 message(s) (999858 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617902871.641|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Received ProduceResponse (v7, 48 bytes, CorrId 9, rtt 28.37ms)
%7|1617902871.641|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [2]: MessageSet with 3183 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617902871.651|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/999909 bytes, CorrId 10)
%7|1617902871.652|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 89706+121276/999909 bytes, CorrId 10)
%7|1617902872.612|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 210982+73025/999909 bytes, CorrId 10)
%7|1617902872.613|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 284007+112853/999909 bytes, CorrId 10)
%7|1617902872.613|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 396860+65536/999909 bytes, CorrId 10)
%7|1617902872.614|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 462396+100126/999909 bytes, CorrId 10)
%7|1617902872.614|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 562522+65536/999909 bytes, CorrId 10)
%7|1617902872.614|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 628058+65536/999909 bytes, CorrId 10)
%7|1617902872.616|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 713122+65536/999953 bytes, CorrId 10)
%7|1617902872.617|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 778658+65536/999953 bytes, CorrId 10)
%7|1617902872.617|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 999953 bytes @ 844194, CorrId 10)
%7|1617902872.632|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 463057+100767/999660 bytes, CorrId 8)
%7|1617902872.637|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [1]: No more space in current MessageSet (3183 message(s), 999928 bytes)
%7|1617902872.643|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [1]: Produce MessageSet with 3183 message(s) (999877 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617902872.644|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Received ProduceResponse (v7, 48 bytes, CorrId 10, rtt 26.36ms)
%7|1617902872.644|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [1]: MessageSet with 3183 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617902872.668|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+0/999928 bytes, CorrId 11)
%7|1617902873.614|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 693594+121024/999909 bytes, CorrId 10)
%7|1617902873.615|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 814618+65536/999909 bytes, CorrId 10)
%7|1617902873.615|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 880154+65536/999909 bytes, CorrId 10)
%7|1617902873.616|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 999909 bytes @ 945690, CorrId 10)
%7|1617902873.618|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 196838+66495/999928 bytes, CorrId 11)
%7|1617902873.619|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 263333+104326/999928 bytes, CorrId 11)
%7|1617902873.619|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 367659+65536/999928 bytes, CorrId 11)
%7|1617902873.633|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 563824+65536/999660 bytes, CorrId 8)
%7|1617902873.636|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [2]: No more space in current MessageSet (3183 message(s), 999926 bytes)
%7|1617902873.642|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [2]: Produce MessageSet with 3183 message(s) (999875 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617902873.643|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Received ProduceResponse (v7, 48 bytes, CorrId 10, rtt 27.06ms)
%7|1617902873.643|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [2]: MessageSet with 3183 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617902873.653|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/999926 bytes, CorrId 11)
%7|1617902874.616|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 97524+119120/999926 bytes, CorrId 11)
%7|1617902874.619|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 433195+89726/999928 bytes, CorrId 11)
%7|1617902874.633|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 629360+65536/999660 bytes, CorrId 8)
%7|1617902875.616|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 216644+75841/999926 bytes, CorrId 11)
%7|1617902875.618|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 292485+119779/999926 bytes, CorrId 11)
%7|1617902875.618|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 412264+65536/999926 bytes, CorrId 11)
%7|1617902875.619|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 477800+110825/999926 bytes, CorrId 11)
%7|1617902875.619|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 588625+65536/999926 bytes, CorrId 11)
%7|1617902875.621|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 522921+232287/999928 bytes, CorrId 11)
%7|1617902875.622|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 755208+65536/999928 bytes, CorrId 11)
%7|1617902875.622|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 820744+65536/999928 bytes, CorrId 11)
%7|1617902875.635|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 694896+121643/999660 bytes, CorrId 8)
%7|1617902875.635|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 816539+65536/999660 bytes, CorrId 8)
%7|1617902876.618|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 654161+65536/999926 bytes, CorrId 11)
%7|1617902876.621|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 999928 bytes @ 886280, CorrId 11)
%7|1617902876.635|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 882075+65536/999660 bytes, CorrId 8)
%7|1617902876.639|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [1]: No more space in current MessageSet (3183 message(s), 999925 bytes)
%7|1617902876.645|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [1]: Produce MessageSet with 3183 message(s) (999874 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617902876.645|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Received ProduceResponse (v7, 48 bytes, CorrId 11, rtt 24.25ms)
%7|1617902876.645|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [1]: MessageSet with 3183 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617902876.657|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+241709/999925 bytes, CorrId 12)
%7|1617902877.619|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 719697+130775/999926 bytes, CorrId 11)
%7|1617902877.623|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 241709+92916/999925 bytes, CorrId 12)
%7|1617902877.623|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 334625+65536/999925 bytes, CorrId 12)
%7|1617902877.636|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 999660 bytes @ 947611, CorrId 8)
%7|1617902877.656|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [0]: No more space in current MessageSet (3183 message(s), 999942 bytes)
%7|1617902877.665|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [0]: Produce MessageSet with 3183 message(s) (999891 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617902877.666|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Received ProduceResponse (v7, 48 bytes, CorrId 8, rtt 29.15ms)
%7|1617902877.666|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [0]: MessageSet with 3182 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617902877.679|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+0/999942 bytes, CorrId 9)
%7|1617902877.680|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 176145+70540/999942 bytes, CorrId 9)
%7|1617902878.620|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 850472+65536/999926 bytes, CorrId 11)
%7|1617902878.621|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 916008+65536/999926 bytes, CorrId 11)
%7|1617902878.621|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 999926 bytes @ 981544, CorrId 11)
%7|1617902878.623|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 400161+69318/999925 bytes, CorrId 12)
%7|1617902878.638|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [2]: Produce MessageSet with 1507 message(s) (473152 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617902878.638|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 246685+93260/999942 bytes, CorrId 9)
%7|1617902878.639|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Received ProduceResponse (v7, 48 bytes, CorrId 11, rtt 17.12ms)
%7|1617902878.639|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 339945+65536/999942 bytes, CorrId 9)
%7|1617902878.639|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [2]: MessageSet with 3183 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617902878.652|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 0+0/473203 bytes, CorrId 12)
%7|1617902878.652|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 135776+70215/473203 bytes, CorrId 12)
%7|1617902878.653|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 205991+75616/473203 bytes, CorrId 12)
%7|1617902878.654|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 281607+112842/473203 bytes, CorrId 12)
%7|1617902879.621|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent partial ProduceRequest (v7, 394449+65536/473203 bytes, CorrId 12)
%7|1617902879.621|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Sent ProduceRequest (v7, 473203 bytes @ 459985, CorrId 12)
%7|1617902879.623|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 469479+65536/999925 bytes, CorrId 12)
%7|1617902879.639|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 405481+74697/999942 bytes, CorrId 9)
%7|1617902879.640|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 480178+131072/999942 bytes, CorrId 9)
%7|1617902879.641|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 611250+145077/999942 bytes, CorrId 9)
%7|1617902879.642|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 756327+131072/999942 bytes, CorrId 9)
%7|1617902879.644|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 999942 bytes @ 887399, CorrId 9)
%7|1617902879.664|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [0]: No more space in current MessageSet (3183 message(s), 999885 bytes)
%7|1617902879.670|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [0]: Produce MessageSet with 3183 message(s) (999834 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617902879.671|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Received ProduceResponse (v7, 48 bytes, CorrId 9, rtt 26.84ms)
%7|1617902879.671|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [0]: MessageSet with 3183 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617902879.680|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+198749/999885 bytes, CorrId 10)
%7|1617902879.682|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 198749+177682/999885 bytes, CorrId 10)
%7|1617902880.768|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: Received ProduceResponse (v7, 48 bytes, CorrId 12, rtt 1146.29ms)
%7|1617902880.768|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: kpis [2]: MessageSet with 1507 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617902880.768|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 535015+65536/999925 bytes, CorrId 12)
%7|1617902880.769|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 376431+65536/999885 bytes, CorrId 10)
%7|1617902881.955|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 600551+74813/999925 bytes, CorrId 12)
%7|1617902881.957|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 675364+196608/999925 bytes, CorrId 12)
%7|1617902881.960|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 441967+94423/999885 bytes, CorrId 10)
%7|1617902882.999|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 536390+65536/999885 bytes, CorrId 10)
%7|1617902882.999|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 871972+108888/999925 bytes, CorrId 12)
%7|1617902884.056|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 601926+65536/999885 bytes, CorrId 10)
%7|1617902884.093|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 999925 bytes @ 980860, CorrId 12)
%7|1617902884.093|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 667462+110963/999885 bytes, CorrId 10)
%7|1617902884.200|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [1]: No more space in current MessageSet (3183 message(s), 999949 bytes)
%7|1617902884.210|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [1]: Produce MessageSet with 3183 message(s) (999898 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617902884.216|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+0/999949 bytes, CorrId 13)
%7|1617902885.098|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 778425+65536/999885 bytes, CorrId 10)
%7|1617902885.101|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 843961+65536/999885 bytes, CorrId 10)
%7|1617902885.103|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Received ProduceResponse (v7, 48 bytes, CorrId 12, rtt 1009.80ms)
%7|1617902885.103|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [1]: MessageSet with 3183 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617902885.198|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 70555+0/999949 bytes, CorrId 13)
%7|1617902885.199|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 163604+66782/999949 bytes, CorrId 13)
%7|1617902886.102|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 909497+65536/999885 bytes, CorrId 10)
%7|1617902886.103|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 999885 bytes @ 975033, CorrId 10)
%7|1617902886.115|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 230386+86952/999949 bytes, CorrId 13)
%7|1617902886.155|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [0]: No more space in current MessageSet (3183 message(s), 999907 bytes)
%7|1617902886.182|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [0]: Produce MessageSet with 3183 message(s) (999856 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617902886.182|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Received ProduceResponse (v7, 48 bytes, CorrId 10, rtt 79.17ms)
%7|1617902886.182|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [0]: MessageSet with 3183 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617902886.204|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+271141/999907 bytes, CorrId 11)
%7|1617902887.107|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 271141+175257/999907 bytes, CorrId 11)
%7|1617902887.139|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 446398+162167/999907 bytes, CorrId 11)
%7|1617902887.140|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 608565+176518/999907 bytes, CorrId 11)
%7|1617902887.145|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 317338+129520/999949 bytes, CorrId 13)
%7|1617902887.148|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 446858+194885/999949 bytes, CorrId 13)
%7|1617902888.108|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 785083+65536/999907 bytes, CorrId 11)
%7|1617902888.145|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 641743+65536/999949 bytes, CorrId 13)
%7|1617902889.110|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 850619+65536/999907 bytes, CorrId 11)
%7|1617902889.111|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 916155+65536/999907 bytes, CorrId 11)
%7|1617902889.146|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 707279+65536/999949 bytes, CorrId 13)
%7|1617902890.141|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 999907 bytes @ 981691, CorrId 11)
%7|1617902890.153|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 772815+160929/999949 bytes, CorrId 13)
%7|1617902890.156|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [0]: Produce MessageSet with 1509 message(s) (473778 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617902890.156|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Received ProduceResponse (v7, 48 bytes, CorrId 11, rtt 15.00ms)
%7|1617902890.156|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [0]: MessageSet with 3183 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617902890.169|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 0+0/473829 bytes, CorrId 12)
%7|1617902890.170|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 97824+119778/473829 bytes, CorrId 12)
%7|1617902890.171|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 217602+77539/473829 bytes, CorrId 12)
%7|1617902892.336|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent partial ProduceRequest (v7, 295141+116619/473829 bytes, CorrId 12)
%7|1617902892.337|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 999949 bytes @ 933744, CorrId 13)
%7|1617902892.337|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Sent ProduceRequest (v7, 473829 bytes @ 411760, CorrId 12)
%7|1617902892.354|PRODUCE|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [1]: Produce MessageSet with 1507 message(s) (473105 bytes, ApiVersion 7, MsgVersion 2, MsgId 0, BaseSeq -1, PID{Invalid}, uncompressed)
%7|1617902892.354|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Received ProduceResponse (v7, 48 bytes, CorrId 13, rtt 17.66ms)
%7|1617902892.354|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [1]: MessageSet with 3183 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617902892.418|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 0+259254/473156 bytes, CorrId 14)
%7|1617902892.421|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 259254+98071/473156 bytes, CorrId 14)
%7|1617902892.422|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent partial ProduceRequest (v7, 357325+65536/473156 bytes, CorrId 14)
%7|1617902893.338|SEND|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Sent ProduceRequest (v7, 473156 bytes @ 422861, CorrId 14)
%7|1617902893.351|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: Received ProduceResponse (v7, 48 bytes, CorrId 12, rtt 1014.56ms)
%7|1617902893.352|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: kpis [0]: MessageSet with 1509 message(s) (MsgId 0, BaseSeq -1) delivered
%7|1617902894.339|RECV|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: Received ProduceResponse (v7, 48 bytes, CorrId 14, rtt 1001.15ms)
%7|1617902894.339|MSGSET|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: kpis [1]: MessageSet with 1507 message(s) (MsgId 0, BaseSeq -1) delivered
...MAINFLUSH: Flushing Messages..
%7|1617902894.368|DESTROY|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: Terminating instance (destroy flags none (0x0))
%7|1617902894.370|DESTROY|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: Destroy internal
%7|1617902894.370|DESTROY|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: Removing all topics
%7|1617902894.372|BRKTERM|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9092/1: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s)
%7|1617902894.373|BRKTERM|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9093/2: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s)
%7|1617902894.374|BRKTERM|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: 192.0.1.2:9094/3: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s)
%7|1617902894.375|BRKTERM|rdkafka#producer-1| [thrd:192.0.1.2:9094/3]: :0/internal: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s)
Debug: End time : 2021-04-08 13:28:14