[2021-06-14 18:29:23,742] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
[2021-06-14 18:29:24,346] INFO Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation (org.apache.zookeeper.common.X509Util)
[2021-06-14 18:29:24,460] TRACE Registered metric named MetricName [name=count, group=kafka-metrics-count, description=total number of registered metrics, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:25,242] TRACE Added sensor with name MemoryPoolUtilization (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:25,258] TRACE Registered metric named MetricName [name=MemoryPoolDepletedTimeTotal, group=socket-server-metrics, description=, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:25,259] TRACE Registered metric named MetricName [name=MemoryPoolAvgDepletedPercent, group=socket-server-metrics, description=, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:25,654] TRACE Added sensor with name Connection-Accept-Rate (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:25,655] TRACE Registered metric named MetricName [name=broker-connection-accept-rate, group=socket-server-metrics, description=Tracking rate of accepting new connections (per second), tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:25,675] DEBUG Initializing task scheduler. (kafka.utils.KafkaScheduler)
[2021-06-14 18:29:25,911] DEBUG Loaded index file /tmp/kraft-logs/__raft_performance_test-0/00000000000000000000.index with maxEntries = 1310720, maxIndexSize = 10485760, entries = 0, lastOffset = 0, file position = 0 (kafka.log.OffsetIndex)
[2021-06-14 18:29:25,922] DEBUG Index /tmp/kraft-logs/__raft_performance_test-0/00000000000000000000.index was not resized because it already has size 10485760 (kafka.log.AbstractIndex)
[2021-06-14 18:29:25,932] DEBUG Loaded index file /tmp/kraft-logs/__raft_performance_test-0/00000000000000000000.timeindex with maxEntries = 873813, maxIndexSize = 10485760, entries = 0, lastOffset = TimestampOffset(-1,0), file position = 0 (kafka.log.TimeIndex)
[2021-06-14 18:29:25,934] DEBUG Index /tmp/kraft-logs/__raft_performance_test-0/00000000000000000000.timeindex was not resized because it already has size 10485756 (kafka.log.AbstractIndex)
[2021-06-14 18:29:25,966] INFO [LogLoader partition=__raft_performance_test-0, dir=/tmp/kraft-logs] Loading producer state till offset 0 with message format version 2 (kafka.log.Log$)
[2021-06-14 18:29:25,969] INFO [LogLoader partition=__raft_performance_test-0, dir=/tmp/kraft-logs] Reloading from producer snapshot and rebuilding producer state from offset 0 (kafka.log.Log$)
[2021-06-14 18:29:25,986] INFO [LogLoader partition=__raft_performance_test-0, dir=/tmp/kraft-logs] Producer state recovery took 4ms for snapshot load and 0ms for segment recovery from offset 0 (kafka.log.Log$)
[2021-06-14 18:29:26,039] DEBUG Scheduling task PeriodicProducerExpirationCheck with initial delay 2147483647 ms and period 2147483647 ms. (kafka.utils.KafkaScheduler)
[2021-06-14 18:29:26,234] TRACE Added sensor with name connections-closed: (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,237] TRACE Registered metric named MetricName [name=connection-close-total, group=raft-channel-metrics, description=The total number of connections closed, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,244] TRACE Registered metric named MetricName [name=connection-close-rate, group=raft-channel-metrics, description=The number of connections closed per second, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,249] TRACE Added sensor with name connections-created: (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,252] TRACE Registered metric named MetricName [name=connection-creation-total, group=raft-channel-metrics, description=The total number of new connections established, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,273] TRACE Registered metric named MetricName [name=connection-creation-rate, group=raft-channel-metrics, description=The number of new connections established per second, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,291] TRACE Added sensor with name successful-authentication: (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,298] TRACE Registered metric named MetricName [name=successful-authentication-total, group=raft-channel-metrics, description=The total number of connections with successful authentication, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,313] TRACE Registered metric named MetricName [name=successful-authentication-rate, group=raft-channel-metrics, description=The number of connections with successful authentication per second, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,328] TRACE Added sensor with name successful-reauthentication: (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,331] TRACE Registered metric named MetricName [name=successful-reauthentication-total, group=raft-channel-metrics, description=The total number of successful re-authentication of connections, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,340] TRACE Registered metric named MetricName [name=successful-reauthentication-rate, group=raft-channel-metrics, description=The number of successful re-authentication of connections per second, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,358] TRACE Added sensor with name successful-authentication-no-reauth: (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,361] TRACE Registered metric named MetricName [name=successful-authentication-no-reauth-total, group=raft-channel-metrics, description=The total number of connections with successful authentication where the client does not support re-authentication, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,367] TRACE Added sensor with name failed-authentication: (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,381] TRACE Registered metric named MetricName [name=failed-authentication-total, group=raft-channel-metrics, description=The total number of connections with failed authentication, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,391] TRACE Registered metric named MetricName [name=failed-authentication-rate, group=raft-channel-metrics, description=The number of connections with failed authentication per second, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,396] TRACE Added sensor with name failed-reauthentication: (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,399] TRACE Registered metric named MetricName [name=failed-reauthentication-total, group=raft-channel-metrics, description=The total number of failed re-authentication of connections, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,428] TRACE Registered metric named MetricName [name=failed-reauthentication-rate, group=raft-channel-metrics, description=The number of failed re-authentication of connections per second, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,432] TRACE Added sensor with name reauthentication-latency: (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,442] TRACE Registered metric named MetricName [name=reauthentication-latency-max, group=raft-channel-metrics, description=The max latency observed due to re-authentication, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,452] TRACE Registered metric named MetricName [name=reauthentication-latency-avg, group=raft-channel-metrics, description=The average latency observed due to re-authentication, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,456] TRACE Added sensor with name bytes-sent-received: (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,459] TRACE Registered metric named MetricName [name=network-io-total, group=raft-channel-metrics, description=The total number of network operations (reads or writes) on all connections, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,481] TRACE Registered metric named MetricName [name=network-io-rate, group=raft-channel-metrics, description=The number of network operations (reads or writes) on all connections per second, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,487] TRACE Added sensor with name bytes-sent: (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,488] TRACE Registered metric named MetricName [name=outgoing-byte-total, group=raft-channel-metrics, description=The total number of outgoing bytes sent to all servers, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,494] TRACE Registered metric named MetricName [name=outgoing-byte-rate, group=raft-channel-metrics, description=The number of outgoing bytes sent to all servers per second, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,513] TRACE Added sensor with name requests-sent: (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,516] TRACE Registered metric named MetricName [name=request-total, group=raft-channel-metrics, description=The total number of requests sent, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,529] TRACE Registered metric named MetricName [name=request-rate, group=raft-channel-metrics, description=The number of requests sent per second, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,547] TRACE Registered metric named MetricName [name=request-size-avg, group=raft-channel-metrics, description=The average size of requests sent., tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,562] TRACE Registered metric named MetricName [name=request-size-max, group=raft-channel-metrics, description=The maximum size of any request sent., tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,574] TRACE Added sensor with name bytes-received: (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,585] TRACE Registered metric named MetricName [name=incoming-byte-total, group=raft-channel-metrics, description=The total number of bytes read off all sockets, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,608] TRACE Registered metric named MetricName [name=incoming-byte-rate, group=raft-channel-metrics, description=The number of bytes read off all sockets per second, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,617] TRACE Added sensor with name responses-received: (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,631] TRACE Registered metric named MetricName [name=response-total, group=raft-channel-metrics, description=The total number of responses received, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,641] TRACE Registered metric named MetricName [name=response-rate, group=raft-channel-metrics, description=The number of responses received per second, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,654] TRACE Added sensor with name select-time: (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,663] TRACE Registered metric named MetricName [name=select-total, group=raft-channel-metrics, description=The total number of times the I/O layer checked for new I/O to perform, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,674] TRACE Registered metric named MetricName [name=select-rate, group=raft-channel-metrics, description=The number of times the I/O layer checked for new I/O to perform per second, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,678] TRACE Registered metric named MetricName [name=io-wait-time-ns-avg, group=raft-channel-metrics, description=The average length of time the I/O thread spent waiting for a socket ready for reads or writes in nanoseconds., tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,685] TRACE Registered metric named MetricName [name=io-waittime-total, group=raft-channel-metrics, description=The total time the I/O thread spent waiting, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,703] TRACE Registered metric named MetricName [name=io-wait-ratio, group=raft-channel-metrics, description=The fraction of time the I/O thread spent waiting, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,706] TRACE Added sensor with name io-time: (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,709] TRACE Registered metric named MetricName [name=io-time-ns-avg, group=raft-channel-metrics, description=The average length of time for I/O per select call in nanoseconds., tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,721] TRACE Registered metric named MetricName [name=iotime-total, group=raft-channel-metrics, description=The total time the I/O thread spent doing I/O, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,734] TRACE Registered metric named MetricName [name=io-ratio, group=raft-channel-metrics, description=The fraction of time the I/O thread spent doing I/O, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,762] TRACE [RaftManager nodeId=0] sslCiphers: created new gauge suite with maxEntries = 100. (org.apache.kafka.common.network.Selector)
[2021-06-14 18:29:26,766] TRACE [RaftManager nodeId=0] clients: created new gauge suite with maxEntries = 100. (org.apache.kafka.common.network.Selector)
[2021-06-14 18:29:26,781] TRACE Registered metric named MetricName [name=connection-count, group=raft-channel-metrics, description=The current number of active connections., tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,878] INFO [raft-expiration-reaper]: Starting (kafka.raft.TimingWheelExpirationService$ExpiredOperationReaper)
[2021-06-14 18:29:26,941] TRACE Registered metric named MetricName [name=current-state, group=raft-metrics, description=The current state of this member; possible values are leader, candidate, voted, follower, unattached, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,951] TRACE Registered metric named MetricName [name=current-leader, group=raft-metrics, description=The current quorum leader's id; -1 indicates unknown, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,969] TRACE Registered metric named MetricName [name=current-vote, group=raft-metrics, description=The current voted leader's id; -1 indicates not voted for anyone, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:26,988] TRACE Registered metric named MetricName [name=current-epoch, group=raft-metrics, description=The current quorum epoch., tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:27,005] TRACE Registered metric named MetricName [name=high-watermark, group=raft-metrics, description=The high watermark maintained on this member; -1 if it is unknown, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:27,013] TRACE Registered metric named MetricName [name=log-end-offset, group=raft-metrics, description=The current raft log end offset., tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:27,033] TRACE Registered metric named MetricName [name=log-end-epoch, group=raft-metrics, description=The current raft log end epoch., tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:27,046] TRACE Registered metric named MetricName [name=number-unknown-voter-connections, group=raft-metrics, description=The number of voter connections recognized at this member., tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:27,063] TRACE Added sensor with name commit-latency (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:27,070] TRACE Registered metric named MetricName [name=commit-latency-avg, group=raft-metrics, description=The average time in milliseconds to commit an entry in the raft log., tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:27,081] TRACE Registered metric named MetricName [name=commit-latency-max, group=raft-metrics, description=The maximum time in milliseconds to commit an entry in the raft log., tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:27,092] TRACE Added sensor with name election-latency (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:27,104] TRACE Registered metric named MetricName [name=election-latency-avg, group=raft-metrics, description=The average time in milliseconds to elect a new leader., tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:27,108] TRACE Registered metric named MetricName [name=election-latency-max, group=raft-metrics, description=The maximum time in milliseconds to elect a new leader., tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:27,112] TRACE Added sensor with name fetch-records (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:27,127] TRACE Registered metric named MetricName [name=fetch-records-rate, group=raft-metrics, description=The average number of records fetched from the leader of the raft quorum., tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:27,131] TRACE Added sensor with name append-records (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:27,134] TRACE Registered metric named MetricName [name=append-records-rate, group=raft-metrics, description=The average number of records appended per sec as the leader of the raft quorum., tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:27,149] TRACE Added sensor with name poll-idle-ratio (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:27,157] TRACE Registered metric named MetricName [name=poll-idle-ratio-avg, group=raft-metrics, description=The average fraction of time the client's poll() is idle as opposed to waiting for the user code to process records., tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:27,713] INFO [RaftManager nodeId=0] Completed transition to Unattached(epoch=0, voters=[0], electionTimeoutMs=1354) (org.apache.kafka.raft.QuorumState)
[2021-06-14 18:29:27,736] INFO [RaftManager nodeId=0] Completed transition to CandidateState(localId=0, epoch=1, retries=1, electionTimeoutMs=1323) (org.apache.kafka.raft.QuorumState)
[2021-06-14 18:29:27,764] INFO [RaftManager nodeId=0] Completed transition to Leader(localId=0, epoch=1, epochStartOffset=0, highWatermark=Optional.empty, voterStates={0=ReplicaState(nodeId=0, endOffset=Optional.empty, lastFetchTimestamp=OptionalLong.empty, hasAcknowledgedLeader=true)}) (org.apache.kafka.raft.QuorumState)
[2021-06-14 18:29:27,783] DEBUG [LeaderEpochCache __raft_performance_test-0] Appended new epoch entry EpochEntry(epoch=1, startOffset=0). Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2021-06-14 18:29:27,895] TRACE Added sensor with name commit.latency (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:27,904] TRACE Registered metric named MetricName [name=commit.latency.p75, group=kafka.raft, description=, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:27,909] TRACE Registered metric named MetricName [name=commit.latency.p99, group=kafka.raft, description=, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:27,923] TRACE Registered metric named MetricName [name=commit.latency.p999, group=kafka.raft, description=, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:27,930] TRACE Added sensor with name bytes.committed (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:27,933] TRACE Registered metric named MetricName [name=bytes.committed.total, group=kafka.raft, description=, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:27,961] TRACE Registered metric named MetricName [name=bytes.committed.rate, group=kafka.raft, description=, tags={}] (org.apache.kafka.common.metrics.Metrics)
[2021-06-14 18:29:28,015] INFO [raft-workload-generator]: Starting (kafka.tools.TestRaftServer$RaftWorkloadGenerator)
[2021-06-14 18:29:28,023] INFO [test-raft-outbound-request-thread]: Starting (kafka.raft.RaftSendThread)
[2021-06-14 18:29:28,025] INFO [SocketServer listenerType=CONTROLLER, nodeId=0] Starting socket server acceptors and processors (kafka.network.SocketServer)
[2021-06-14 18:29:28,024] INFO [test-raft-io-thread]: Starting (kafka.raft.KafkaRaftManager$RaftIoThread)
[2021-06-14 18:29:28,117] INFO [SocketServer listenerType=CONTROLLER, nodeId=0] Started socket server acceptors and processors (kafka.network.SocketServer)
[2021-06-14 18:29:28,136] ERROR [raft-workload-generator]: Error due to (kafka.tools.TestRaftServer$RaftWorkloadGenerator)
scala.MatchError: null
        at kafka.tools.TestRaftServer$RaftWorkloadGenerator.doWork(TestRaftServer.scala:213)
        at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96)
[2021-06-14 18:29:28,161] INFO [raft-workload-generator]: Stopped (kafka.tools.TestRaftServer$RaftWorkloadGenerator)
[2021-06-14 18:29:28,171] TRACE Inserting 89 bytes at end offset 0 at position 0 with largest timestamp 1623709767714 at shallow offset 0 (kafka.log.LogSegment)
[2021-06-14 18:29:28,188] TRACE Appended 89 to /tmp/kraft-logs/__raft_performance_test-0/00000000000000000000.log at end offset 0 (kafka.log.LogSegment)
[2021-06-14 18:29:28,206] TRACE [Log partition=__raft_performance_test-0, dir=/tmp/kraft-logs] Appended message set with last offset: 0, first offset: Some((offset=0 segment=[0:0])), next offset: 1, and messages: MemoryRecords(size=89, buffer=java.nio.HeapByteBuffer[pos=0 lim=89 cap=8388608]) (kafka.log.Log)
[2021-06-14 18:29:28,249] TRACE [Log partition=__raft_performance_test-0, dir=/tmp/kraft-logs] Setting high watermark (offset=1 segment=[0:89]) (kafka.log.Log)
[2021-06-14 18:29:28,281] TRACE [Log partition=__raft_performance_test-0, dir=/tmp/kraft-logs] Reading maximum 8388608 bytes at offset 0 from log with total length 89 bytes (kafka.log.Log)
[2021-06-14 18:29:28,330] DEBUG [Log partition=__raft_performance_test-0, dir=/tmp/kraft-logs] Flushing log up to offset 1, last flushed: 1623709766021,  current time: 1623709768330, unflushed: 1 (kafka.log.Log)
[2021-06-14 18:29:28,383] TRACE Inserting 326 bytes at end offset 1 at position 89 with largest timestamp 1623709768120 at shallow offset 1 (kafka.log.LogSegment)
[2021-06-14 18:29:28,386] TRACE Appended 326 to /tmp/kraft-logs/__raft_performance_test-0/00000000000000000000.log at end offset 1 (kafka.log.LogSegment)
[2021-06-14 18:29:28,388] TRACE [Log partition=__raft_performance_test-0, dir=/tmp/kraft-logs] Appended message set with last offset: 1, first offset: Some((offset=1 segment=[0:89])), next offset: 2, and messages: MemoryRecords(size=326, buffer=java.nio.HeapByteBuffer[pos=0 lim=326 cap=326]) (kafka.log.Log)
[2021-06-14 18:29:28,393] TRACE [Log partition=__raft_performance_test-0, dir=/tmp/kraft-logs] Setting high watermark (offset=2 segment=[0:415]) (kafka.log.Log)
[2021-06-14 18:29:28,399] DEBUG [Log partition=__raft_performance_test-0, dir=/tmp/kraft-logs] Flushing log up to offset 2, last flushed: 1623709768377,  current time: 1623709768399, unflushed: 1 (kafka.log.Log)