publish_sendsEventToTopic()

2026-10-18T21:56:25.817Z  INFO 2418 --- [ntainer#0-0-C-1] org.apache.kafka.clients.Metadata        : [Consumer clientId=consumer-kafka-guarantees-lab-group-10, groupId=kafka-guarantees-lab-group] Cluster ID: DCMAT5tLTbuvLtZsfTZPTw
2026-10-18T21:56:25.817Z  INFO 2418 --- [quest-handler-2] k.s.DefaultAutoTopicCreationManager      : Sent auto-creation request for Set(__consumer_offsets) to the active controller.
2026-10-18T21:56:25.818Z  INFO 2418 --- [    Test worker] c.m.k.p.LanguagePreferenceProducer       : Publishing event: customerId=cust-1
2026-10-18T21:56:25.818Z  INFO 2418 --- [    Test worker] o.a.kafka.common.config.AbstractConfig   : ProducerConfig values: 
	acks = -1
	batch.size = 16384
	bootstrap.servers = [localhost:41123]
	buffer.memory = 33554432
	client.dns.lookup = use_all_dns_ips
	client.id = producer-3
	compression.gzip.level = -1
	compression.lz4.level = 9
	compression.type = none
	compression.zstd.level = 3
	config.providers = []
	connections.max.idle.ms = 540000
	delivery.timeout.ms = 120000
	enable.idempotence = true
	enable.metrics.push = true
	interceptor.classes = []
	key.serializer = class org.apache.kafka.common.serialization.StringSerializer
	linger.ms = 5
	max.block.ms = 60000
	max.in.flight.requests.per.connection = 5
	max.request.size = 1048576
	metadata.max.age.ms = 300000
	metadata.max.idle.ms = 300000
	metadata.recovery.rebootstrap.trigger.ms = 300000
	metadata.recovery.strategy = rebootstrap
	metric.reporters = [org.apache.kafka.common.metrics.JmxReporter]
	metrics.num.samples = 2
	metrics.recording.level = INFO
	metrics.sample.window.ms = 30000
	partitioner.adaptive.partitioning.enable = true
	partitioner.availability.timeout.ms = 0
	partitioner.class = null
	partitioner.ignore.keys = false
	receive.buffer.bytes = 32768
	reconnect.backoff.max.ms = 1000
	reconnect.backoff.ms = 50
	request.timeout.ms = 30000
	retries = 2147483647
	retry.backoff.max.ms = 1000
	retry.backoff.ms = 100
	sasl.client.callback.handler.class = null
	sasl.jaas.config = null
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.min.time.before.relogin = 60000
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	sasl.kerberos.ticket.renew.window.factor = 0.8
	sasl.login.callback.handler.class = null
	sasl.login.class = null
	sasl.login.connect.timeout.ms = null
	sasl.login.read.timeout.ms = null
	sasl.login.refresh.buffer.seconds = 300
	sasl.login.refresh.min.period.seconds = 60
	sasl.login.refresh.window.factor = 0.8
	sasl.login.refresh.window.jitter = 0.05
	sasl.login.retry.backoff.max.ms = 10000
	sasl.login.retry.backoff.ms = 100
	sasl.mechanism = GSSAPI
	sasl.oauthbearer.assertion.algorithm = RS256
	sasl.oauthbearer.assertion.claim.aud = null
	sasl.oauthbearer.assertion.claim.exp.seconds = 300
	sasl.oauthbearer.assertion.claim.iss = null
	sasl.oauthbearer.assertion.claim.jti.include = false
	sasl.oauthbearer.assertion.claim.nbf.seconds = 60
	sasl.oauthbearer.assertion.claim.sub = null
	sasl.oauthbearer.assertion.file = null
	sasl.oauthbearer.assertion.private.key.file = null
	sasl.oauthbearer.assertion.private.key.passphrase = null
	sasl.oauthbearer.assertion.template.file = null
	sasl.oauthbearer.client.credentials.client.id = null
	sasl.oauthbearer.client.credentials.client.secret = null
	sasl.oauthbearer.clock.skew.seconds = 30
	sasl.oauthbearer.expected.audience = []
	sasl.oauthbearer.expected.issuer = null
	sasl.oauthbearer.header.urlencode = false
	sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000
	sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000
	sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100
	sasl.oauthbearer.jwks.endpoint.url = null
	sasl.oauthbearer.jwt.retriever.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtRetriever
	sasl.oauthbearer.jwt.validator.class = class org.apache.kafka.common.security.oauthbearer.DefaultJwtValidator
	sasl.oauthbearer.scope = null
	sasl.oauthbearer.scope.claim.name = scope
	sasl.oauthbearer.sub.claim.name = sub
	sasl.oauthbearer.token.endpoint.url = null
	security.protocol = PLAINTEXT
	security.providers = null
	send.buffer.bytes = 131072
	socket.connection.setup.timeout.max.ms = 30000
	socket.connection.setup.timeout.ms = 10000
	ssl.cipher.suites = []
	ssl.enabled.protocols = [TLSv1.2, TLSv1.3]
	ssl.endpoint.identification.algorithm = https
	ssl.engine.factory.class = null
	ssl.key.password = null
	ssl.keymanager.algorithm = SunX509
	ssl.keystore.certificate.chain = null
	ssl.keystore.key = null
	ssl.keystore.location = null
	ssl.keystore.password = null
	ssl.keystore.type = JKS
	ssl.protocol = TLSv1.3
	ssl.provider = null
	ssl.secure.random.implementation = null
	ssl.trustmanager.algorithm = PKIX
	ssl.truststore.certificates = null
	ssl.truststore.location = null
	ssl.truststore.password = null
	ssl.truststore.type = JKS
	transaction.timeout.ms = 60000
	transaction.two.phase.commit.enable = false
	transactional.id = null
	value.serializer = class org.springframework.kafka.support.serializer.JacksonJsonSerializer

2026-10-18T21:56:25.819Z  INFO 2418 --- [    Test worker] o.a.k.c.t.i.KafkaMetricsCollector        : initializing Kafka metrics collector
2026-10-18T21:56:25.819Z  INFO 2418 --- [    Test worker] o.a.k.clients.producer.KafkaProducer     : [Producer clientId=producer-3] Instantiated an idempotent producer.
2026-10-18T21:56:25.820Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] CreateTopics result(s): CreatableTopic(name='__consumer_offsets', numPartitions=50, replicationFactor=1, assignments=[], configs=[CreatableTopicConfig(name='compression.type', value='producer'), CreatableTopicConfig(name='cleanup.policy', value='compact'), CreatableTopicConfig(name='segment.bytes', value='104857600')]): SUCCESS
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed TopicRecord for topic __consumer_offsets with topic ID Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ConfigurationControlManager      : [QuorumController id=0] Replayed ConfigRecord for ConfigResource(type=TOPIC, name='__consumer_offsets') which set configuration compression.type to producer
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ConfigurationControlManager      : [QuorumController id=0] Replayed ConfigRecord for ConfigResource(type=TOPIC, name='__consumer_offsets') which set configuration cleanup.policy to compact
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ConfigurationControlManager      : [QuorumController id=0] Replayed ConfigRecord for ConfigResource(type=TOPIC, name='__consumer_offsets') which set configuration segment.bytes to 104857600
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-0 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-1 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-2 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-3 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-4 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-5 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-6 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-7 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-8 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-9 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-10 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-11 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-12 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-13 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-14 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-15 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-16 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-17 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-18 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-19 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-20 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-21 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-22 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-23 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-24 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-25 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-26 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-27 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-28 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-29 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-30 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-31 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-32 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-33 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.821Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-34 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.822Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-35 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.822Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-36 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.822Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-37 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.822Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-38 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.822Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-39 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.822Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-40 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.822Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-41 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.822Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-42 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.822Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-43 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.822Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-44 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.822Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-45 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.822Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-46 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.822Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-47 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.822Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-48 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.822Z  INFO 2418 --- [0-event-handler] o.a.k.c.ReplicationControlManager        : [QuorumController id=0] Replayed PartitionRecord for new partition __consumer_offsets-49 with topic ID Aw2fgE8WTueFtzPDM0nU5A and PartitionRegistration(replicas=[0], directories=[lyzfAnKrgVZNnUqCdIs7vA], isr=[0], removingReplicas=[], addingReplicas=[], elr=[], lastKnownElr=[], leader=0, leaderRecoveryState=RECOVERED, leaderEpoch=0, partitionEpoch=0).
2026-10-18T21:56:25.822Z  INFO 2418 --- [    Test worker] o.a.kafka.common.utils.AppInfoParser     : Kafka version: 4.2.1
2026-10-18T21:56:25.822Z  INFO 2418 --- [    Test worker] o.a.kafka.common.utils.AppInfoParser     : Kafka commitId: 92f61c44867f39dc
2026-10-18T21:56:25.822Z  INFO 2418 --- [    Test worker] o.a.kafka.common.utils.AppInfoParser     : Kafka startTimeMs: 1792360585822
2026-10-18T21:56:25.825Z  INFO 2418 --- [ad | producer-3] org.apache.kafka.clients.Metadata        : [Producer clientId=producer-3] Cluster ID: DCMAT5tLTbuvLtZsfTZPTw
2026-10-18T21:56:25.848Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Transitioning 50 partition(s) to local leaders.
2026-10-18T21:56:25.848Z  INFO 2418 --- [r-event-handler] kafka.server.ReplicaFetcherManager       : [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(__consumer_offsets-13, __consumer_offsets-46, __consumer_offsets-9, __consumer_offsets-42, __consumer_offsets-21, __consumer_offsets-17, __consumer_offsets-30, __consumer_offsets-26, __consumer_offsets-5, __consumer_offsets-38, __consumer_offsets-1, __consumer_offsets-34, __consumer_offsets-16, __consumer_offsets-45, __consumer_offsets-12, __consumer_offsets-41, __consumer_offsets-24, __consumer_offsets-20, __consumer_offsets-49, __consumer_offsets-0, __consumer_offsets-29, __consumer_offsets-25, __consumer_offsets-8, __consumer_offsets-37, __consumer_offsets-4, __consumer_offsets-33, __consumer_offsets-15, __consumer_offsets-48, __consumer_offsets-11, __consumer_offsets-44, __consumer_offsets-23, __consumer_offsets-19, __consumer_offsets-32, __consumer_offsets-28, __consumer_offsets-7, __consumer_offsets-40, __consumer_offsets-3, __consumer_offsets-36, __consumer_offsets-47, __consumer_offsets-14, __consumer_offsets-43, __consumer_offsets-10, __consumer_offsets-22, __consumer_offsets-18, __consumer_offsets-31, __consumer_offsets-27, __consumer_offsets-39, __consumer_offsets-6, __consumer_offsets-35, __consumer_offsets-2)
2026-10-18T21:56:25.848Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-13 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.849Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-13, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.850Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-13 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-13 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.850Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-13 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-13
2026-10-18T21:56:25.850Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-13 broker=0] Log loaded for partition __consumer_offsets-13 with initial high watermark 0
2026-10-18T21:56:25.850Z  INFO 2418 --- [0-event-handler] o.a.k.c.ProducerIdControlManager         : [QuorumController id=0] Replaying ProducerIdsRecord ProducerIdsRecord(brokerId=0, brokerEpoch=10, nextProducerId=1000)
2026-10-18T21:56:25.850Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-13 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.850Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-46 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.851Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-46, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.851Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-46 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-46 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.851Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-46 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-46
2026-10-18T21:56:25.851Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-46 broker=0] Log loaded for partition __consumer_offsets-46 with initial high watermark 0
2026-10-18T21:56:25.851Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-46 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.852Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-9 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.852Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-9, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.852Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-9 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-9 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.852Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-9 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-9
2026-10-18T21:56:25.853Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-9 broker=0] Log loaded for partition __consumer_offsets-9 with initial high watermark 0
2026-10-18T21:56:25.853Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-9 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.853Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-42 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.854Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-42, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.854Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-42 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-42 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.854Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-42 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-42
2026-10-18T21:56:25.854Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-42 broker=0] Log loaded for partition __consumer_offsets-42 with initial high watermark 0
2026-10-18T21:56:25.854Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-42 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.855Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-21 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.855Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-21, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.855Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-21 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-21 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.855Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-21 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-21
2026-10-18T21:56:25.855Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-21 broker=0] Log loaded for partition __consumer_offsets-21 with initial high watermark 0
2026-10-18T21:56:25.855Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-21 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.856Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-17 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.857Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-17, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.857Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-17 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-17 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.857Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-17 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-17
2026-10-18T21:56:25.857Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-17 broker=0] Log loaded for partition __consumer_offsets-17 with initial high watermark 0
2026-10-18T21:56:25.857Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-17 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.857Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-30 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.858Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-30, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.858Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-30 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-30 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.858Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-30 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-30
2026-10-18T21:56:25.858Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-30 broker=0] Log loaded for partition __consumer_offsets-30 with initial high watermark 0
2026-10-18T21:56:25.858Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-30 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.859Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-26 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.859Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-26, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.859Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-26 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-26 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.860Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-26 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-26
2026-10-18T21:56:25.860Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-26 broker=0] Log loaded for partition __consumer_offsets-26 with initial high watermark 0
2026-10-18T21:56:25.860Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-26 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.860Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-5 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.861Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-5, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.861Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-5 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-5 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.861Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-5 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-5
2026-10-18T21:56:25.861Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-5 broker=0] Log loaded for partition __consumer_offsets-5 with initial high watermark 0
2026-10-18T21:56:25.861Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-5 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.861Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-38 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.862Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-38, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.862Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-38 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-38 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.862Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-38 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-38
2026-10-18T21:56:25.862Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-38 broker=0] Log loaded for partition __consumer_offsets-38 with initial high watermark 0
2026-10-18T21:56:25.862Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-38 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.863Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-1 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.864Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-1, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.864Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-1 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-1 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.864Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-1 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-1
2026-10-18T21:56:25.864Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-1 broker=0] Log loaded for partition __consumer_offsets-1 with initial high watermark 0
2026-10-18T21:56:25.864Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-1 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.866Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-34 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.867Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-34, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.867Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-34 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-34 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.867Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-34 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-34
2026-10-18T21:56:25.867Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-34 broker=0] Log loaded for partition __consumer_offsets-34 with initial high watermark 0
2026-10-18T21:56:25.867Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-34 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.867Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-16 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.868Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-16, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.868Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-16 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-16 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.868Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-16 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-16
2026-10-18T21:56:25.868Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-16 broker=0] Log loaded for partition __consumer_offsets-16 with initial high watermark 0
2026-10-18T21:56:25.868Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-16 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.869Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-45 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.870Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-45, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.870Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-45 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-45 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.870Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-45 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-45
2026-10-18T21:56:25.870Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-45 broker=0] Log loaded for partition __consumer_offsets-45 with initial high watermark 0
2026-10-18T21:56:25.870Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-45 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.871Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-12 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.871Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-12, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.872Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-12 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-12 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.872Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-12 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-12
2026-10-18T21:56:25.872Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-12 broker=0] Log loaded for partition __consumer_offsets-12 with initial high watermark 0
2026-10-18T21:56:25.872Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-12 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.872Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-41 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.873Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-41, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.873Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-41 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-41 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.873Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-41 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-41
2026-10-18T21:56:25.873Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-41 broker=0] Log loaded for partition __consumer_offsets-41 with initial high watermark 0
2026-10-18T21:56:25.873Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-41 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.874Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-24 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.875Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-24, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.875Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-24 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-24 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.875Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-24 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-24
2026-10-18T21:56:25.875Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-24 broker=0] Log loaded for partition __consumer_offsets-24 with initial high watermark 0
2026-10-18T21:56:25.875Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-24 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.876Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-20 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.877Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-20, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.877Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-20 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-20 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.877Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-20 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-20
2026-10-18T21:56:25.877Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-20 broker=0] Log loaded for partition __consumer_offsets-20 with initial high watermark 0
2026-10-18T21:56:25.877Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-20 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.877Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-49 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.878Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-49, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.878Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-49 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-49 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.878Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-49 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-49
2026-10-18T21:56:25.878Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-49 broker=0] Log loaded for partition __consumer_offsets-49 with initial high watermark 0
2026-10-18T21:56:25.878Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-49 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.879Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-0 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.880Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-0, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.880Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-0 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-0 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.880Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-0 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-0
2026-10-18T21:56:25.880Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-0 broker=0] Log loaded for partition __consumer_offsets-0 with initial high watermark 0
2026-10-18T21:56:25.880Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-0 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.889Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-29 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.890Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-29, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.890Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-29 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-29 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.890Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-29 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-29
2026-10-18T21:56:25.890Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-29 broker=0] Log loaded for partition __consumer_offsets-29 with initial high watermark 0
2026-10-18T21:56:25.890Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-29 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.891Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-25 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.891Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-25, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.891Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-25 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-25 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.891Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-25 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-25
2026-10-18T21:56:25.891Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-25 broker=0] Log loaded for partition __consumer_offsets-25 with initial high watermark 0
2026-10-18T21:56:25.891Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-25 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.892Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-8 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.893Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-8, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.893Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-8 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-8 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.893Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-8 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-8
2026-10-18T21:56:25.893Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-8 broker=0] Log loaded for partition __consumer_offsets-8 with initial high watermark 0
2026-10-18T21:56:25.893Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-8 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.894Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-37 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.895Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-37, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.895Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-37 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-37 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.895Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-37 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-37
2026-10-18T21:56:25.895Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-37 broker=0] Log loaded for partition __consumer_offsets-37 with initial high watermark 0
2026-10-18T21:56:25.895Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-37 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.895Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-4 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.896Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-4, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.896Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-4 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-4 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.896Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-4 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-4
2026-10-18T21:56:25.896Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-4 broker=0] Log loaded for partition __consumer_offsets-4 with initial high watermark 0
2026-10-18T21:56:25.896Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-4 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.897Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-33 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.898Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-33, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.898Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-33 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-33 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.898Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-33 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-33
2026-10-18T21:56:25.898Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-33 broker=0] Log loaded for partition __consumer_offsets-33 with initial high watermark 0
2026-10-18T21:56:25.898Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-33 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.898Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-15 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.899Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-15, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.899Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-15 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-15 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.899Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-15 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-15
2026-10-18T21:56:25.899Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-15 broker=0] Log loaded for partition __consumer_offsets-15 with initial high watermark 0
2026-10-18T21:56:25.899Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-15 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.900Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-48 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.900Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-48, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.900Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-48 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-48 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.900Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-48 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-48
2026-10-18T21:56:25.901Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-48 broker=0] Log loaded for partition __consumer_offsets-48 with initial high watermark 0
2026-10-18T21:56:25.901Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-48 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.901Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-11 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.902Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-11, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.902Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-11 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-11 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.902Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-11 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-11
2026-10-18T21:56:25.902Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-11 broker=0] Log loaded for partition __consumer_offsets-11 with initial high watermark 0
2026-10-18T21:56:25.902Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-11 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.903Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-44 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.903Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-44, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.903Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-44 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-44 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.903Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-44 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-44
2026-10-18T21:56:25.903Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-44 broker=0] Log loaded for partition __consumer_offsets-44 with initial high watermark 0
2026-10-18T21:56:25.903Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-44 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.904Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-23 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.905Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-23, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.905Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-23 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-23 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.905Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-23 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-23
2026-10-18T21:56:25.905Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-23 broker=0] Log loaded for partition __consumer_offsets-23 with initial high watermark 0
2026-10-18T21:56:25.905Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-23 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.905Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-19 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.906Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-19, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.906Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-19 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-19 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.906Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-19 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-19
2026-10-18T21:56:25.906Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-19 broker=0] Log loaded for partition __consumer_offsets-19 with initial high watermark 0
2026-10-18T21:56:25.906Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-19 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.907Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-32 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.907Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-32, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.907Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-32 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-32 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.907Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-32 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-32
2026-10-18T21:56:25.907Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-32 broker=0] Log loaded for partition __consumer_offsets-32 with initial high watermark 0
2026-10-18T21:56:25.907Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-32 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.908Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-28 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.909Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-28, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.909Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-28 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-28 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.909Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-28 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-28
2026-10-18T21:56:25.909Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-28 broker=0] Log loaded for partition __consumer_offsets-28 with initial high watermark 0
2026-10-18T21:56:25.909Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-28 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.909Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-7 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.910Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-7, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.910Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-7 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-7 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.910Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-7 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-7
2026-10-18T21:56:25.910Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-7 broker=0] Log loaded for partition __consumer_offsets-7 with initial high watermark 0
2026-10-18T21:56:25.910Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-7 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.911Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-40 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.911Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-40, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.912Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-40 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-40 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.912Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-40 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-40
2026-10-18T21:56:25.912Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-40 broker=0] Log loaded for partition __consumer_offsets-40 with initial high watermark 0
2026-10-18T21:56:25.912Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-40 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.912Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-3 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.913Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-3, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.913Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-3 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-3 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.913Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-3 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-3
2026-10-18T21:56:25.913Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-3 broker=0] Log loaded for partition __consumer_offsets-3 with initial high watermark 0
2026-10-18T21:56:25.913Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-3 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.914Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-36 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.914Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-36, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.914Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-36 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-36 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.914Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-36 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-36
2026-10-18T21:56:25.914Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-36 broker=0] Log loaded for partition __consumer_offsets-36 with initial high watermark 0
2026-10-18T21:56:25.914Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-36 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.915Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-47 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.916Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-47, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.916Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-47 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-47 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.916Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-47 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-47
2026-10-18T21:56:25.916Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-47 broker=0] Log loaded for partition __consumer_offsets-47 with initial high watermark 0
2026-10-18T21:56:25.916Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-47 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.916Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-14 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.917Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-14, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.917Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-14 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-14 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.917Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-14 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-14
2026-10-18T21:56:25.917Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-14 broker=0] Log loaded for partition __consumer_offsets-14 with initial high watermark 0
2026-10-18T21:56:25.917Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-14 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.918Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-43 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.918Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-43, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.919Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-43 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-43 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.919Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-43 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-43
2026-10-18T21:56:25.919Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-43 broker=0] Log loaded for partition __consumer_offsets-43 with initial high watermark 0
2026-10-18T21:56:25.919Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-43 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.919Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-10 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.920Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-10, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.920Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-10 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-10 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.920Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-10 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-10
2026-10-18T21:56:25.920Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-10 broker=0] Log loaded for partition __consumer_offsets-10 with initial high watermark 0
2026-10-18T21:56:25.921Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-10 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.921Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-22 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.922Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-22, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.922Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-22 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-22 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.922Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-22 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-22
2026-10-18T21:56:25.922Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-22 broker=0] Log loaded for partition __consumer_offsets-22 with initial high watermark 0
2026-10-18T21:56:25.922Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-22 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.923Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-18 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.923Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-18, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.924Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-18 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-18 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.924Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-18 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-18
2026-10-18T21:56:25.924Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-18 broker=0] Log loaded for partition __consumer_offsets-18 with initial high watermark 0
2026-10-18T21:56:25.924Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-18 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.924Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-31 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.925Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-31, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.925Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-31 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-31 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.925Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-31 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-31
2026-10-18T21:56:25.925Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-31 broker=0] Log loaded for partition __consumer_offsets-31 with initial high watermark 0
2026-10-18T21:56:25.925Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-31 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.926Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-27 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.926Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-27, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.926Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-27 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-27 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.926Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-27 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-27
2026-10-18T21:56:25.926Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-27 broker=0] Log loaded for partition __consumer_offsets-27 with initial high watermark 0
2026-10-18T21:56:25.926Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-27 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.927Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-39 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.928Z  INFO 2418 --- [ad | producer-3] o.a.k.c.p.internals.TransactionManager   : [Producer clientId=producer-3] ProducerId set to 0 with epoch 0
2026-10-18T21:56:25.928Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-39, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.928Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-39 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-39 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.928Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-39 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-39
2026-10-18T21:56:25.928Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-39 broker=0] Log loaded for partition __consumer_offsets-39 with initial high watermark 0
2026-10-18T21:56:25.928Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-39 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.929Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-6 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.929Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-6, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.929Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-6 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-6 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.929Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-6 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-6
2026-10-18T21:56:25.929Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-6 broker=0] Log loaded for partition __consumer_offsets-6 with initial high watermark 0
2026-10-18T21:56:25.930Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-6 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.930Z  INFO 2418 --- [ad | producer-3] c.m.k.p.LanguagePreferenceProducer       : Published event: customerId=cust-1 partition=0 offset=0
2026-10-18T21:56:25.930Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-35 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.931Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-35, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.931Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-35 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-35 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.931Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-35 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-35
2026-10-18T21:56:25.931Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-35 broker=0] Log loaded for partition __consumer_offsets-35 with initial high watermark 0
2026-10-18T21:56:25.931Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-35 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.931Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Creating new partition __consumer_offsets-2 with topic id Aw2fgE8WTueFtzPDM0nU5A.
2026-10-18T21:56:25.932Z  INFO 2418 --- [r-event-handler] o.a.k.storage.internals.log.UnifiedLog   : [LogLoader partition=__consumer_offsets-2, dir=/tmp/kafka-893651619888851807/combined_0_0] Loading producer state till offset 0
2026-10-18T21:56:25.932Z  INFO 2418 --- [r-event-handler] kafka.log.LogManager                     : Created log for partition __consumer_offsets-2 in /tmp/kafka-893651619888851807/combined_0_0/__consumer_offsets-2 with properties {cleanup.policy=compact, compression.type="producer", segment.bytes=104857600}
2026-10-18T21:56:25.932Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-2 broker=0] No checkpointed highwatermark is found for partition __consumer_offsets-2
2026-10-18T21:56:25.932Z  INFO 2418 --- [r-event-handler] kafka.cluster.Partition                  : [Partition __consumer_offsets-2 broker=0] Log loaded for partition __consumer_offsets-2 with initial high watermark 0
2026-10-18T21:56:25.932Z  INFO 2418 --- [r-event-handler] state.change.logger                      : [Broker id=0] Leader __consumer_offsets-2 with topic id Some(Aw2fgE8WTueFtzPDM0nU5A) starts at leader epoch 0 from offset 0 with partition epoch 0, high watermark 0, ISR [0], adding replicas [] and removing replicas [] . Previous leader None and previous leader epoch was -1.
2026-10-18T21:56:25.934Z  INFO 2418 --- [r-event-handler] o.a.k.c.c.runtime.CoordinatorRuntime     : [GroupCoordinator id=0] Scheduling loading of metadata from __consumer_offsets-13 with epoch 0
2026-10-18T21:56:25.934Z  INFO 2418 --- [r-event-handler] o.a.k.c.c.runtime.CoordinatorRuntime     : [GroupCoordinator id=0] Scheduling loading of metadata from __consumer_offsets-46 with epoch 0
2026-10-18T21:56:25.934Z  INFO 2418 --- [r-event-handler] o.a.k.c.c.runtime.CoordinatorRuntime     : [GroupCoordinator id=0] Scheduling loading of metadata from __consumer_offsets-9 with epoch 0
2026-10-18T21:56:25.934Z  INFO 2418 --- [r-event-handler] o.a.k.c.c.runtime.CoordinatorRuntime     : [GroupCoordinator id=0] Scheduling loading of metadata from __consumer_offsets-42 with epoch 0
2026-10-18T21:56:25.934Z  INFO 2418 --- [r-event-handler] o.a.k.c.c.runtime.CoordinatorRuntime     : [GroupCoordinator id=0] Scheduling loading of metadata from __consumer_offsets-21 with epoch 0
2026-10-18T21:56:25.934Z  INFO 2418 --- [r-event-handler] o.a.k.c.c.runtime.CoordinatorRuntime     : [GroupCoordinator id=0] Scheduling loading of metadata from __consumer_offsets-17 with epoch 0
2026-10-18T21:56:25.934Z  INFO 2418 --- [r-event-handler] o.a.k.c.c.runtime.CoordinatorRuntime     : [GroupCoordinator id=0] Scheduling loading of metadata from __consumer_offsets-30 with epoch 0
2026-10-18T21:56:25.934Z  INFO 2418 --- [r-event-handler] o.a.k.c.c.runtime.CoordinatorRuntime     : [GroupCoordinator id=0] Scheduling loading of metadata from __consumer_offsets-26 with epoch 0
2026-10-18T21:56:25.934Z  INFO 2418 --- [r-event-handler] o.a.k.c.c.runtime.CoordinatorRuntime     : [GroupCoordinator id=0] Scheduling loading of metadata from __consumer_offsets-5 with epoch 0
2026-10-18T21:56:25.934Z  INFO 2418 --- [r-event-handler] o.a.k.c.c.runtime.CoordinatorRuntime     : [GroupCoordinator id=0] Scheduling loading of metadata from __consumer_offsets-38 with epoch 0
2026-10-18T21:56:25.934Z  INFO 2418 --- [r-event-handler] o.a.k.c.c.runtime.CoordinatorRuntime     : [GroupCoordinator id=0] Scheduling loading of metadata from __consumer_offsets-1 with epoch 0
2026-10-18T21:56:25.934Z  INFO 2418 --- [r-event-handler] o.a.k.c.c.runtime.CoordinatorRuntime     : [GroupCoordinator id=0] Scheduling loading of metadata from __consumer_offsets-34 with epoch 0
2026-10-18T21:56:25.934Z  INFO 2418 --- [r-event-handler] o.a.k.c.c.runtime.CoordinatorRuntime     : [GroupCoordinator id=0] Scheduling loading of metadata from __consumer_offsets-16 with epoch 0
2026-10-18T21:56:25.934Z  INFO 2418 --- [r-event-handler] o.a.k.c.c.runtime.CoordinatorRuntime     : [GroupCoordinator id=0] Scheduling loading of metadata from __consumer_offsets-45 with epoch 0
2026-10-18T21:56:25.934Z  INFO 2418 --- [r-event-handler] o.a.k.c.c.runtime.CoordinatorRuntime     : [GroupCoordinator id=0] Scheduling loading of metadata from __consumer_offsets-12 with epoch 0
2026-10-18T21:56:25.934Z  INFO 2418 --- [r-event-handler] o.a.k.c.c.runtime.CoordinatorRuntime     : [GroupCoordinator id=0] Scheduling loading of metadata from __consumer_offsets-41 with epoch 0
2026-10-18T21:56:25.934Z  INFO 2418 --- [r-event-handler] o.a.k.c.c.runtime.CoordinatorRuntime     : [GroupCoordinator id=0] Scheduling loading of metadata from __consumer_offsets-24 with epoch 0
2026-10-18T21:56:25.934Z  INFO 2418 --- [r-event-handler] o.a.k.c.c.runtime.CoordinatorRuntime     : [GroupCoordinator id=0] Scheduling loading of metadata from __consumer_offsets-20 with epoch 0
2026-10-18T21:56:25.934Z  INFO 2418 --- [r-event-handler] o.a.k.c.c.runtime.CoordinatorRuntime     : [GroupCoordinator id=0] Scheduling loading of metadata from __consumer_offsets-49 with epoch 0
2026-10-18T21:56:25.934Z  INFO 2418 --- [r-event-handler] o.a.k.c.c.runtime.CoordinatorRuntime     : [GroupCoordinator id=0] Scheduling loading of metadata from __consumer_offsets-0 with epoch 0
2026-10-18T21:56:25.934Z  INFO 2418 --- [r-event-handler] o.a.k.c.c.runtime.CoordinatorRuntime     : [GroupCoordinator id=0] Scheduling loading of metadata from __consumer_offsets-29 with epoch 0