11:40:16.300 WARN  [Source: TransactionSource -> Sink: print (1/1)#0] org.apache.kafka.clients.consumer.ConsumerConfig - These configurations '[client.id.prefix, <http://partition.discovery.interval.ms|partition.discovery.interval.ms>]' were supplied but are not used yet.
11:40:16.300 INFO  [Source: TransactionSource -> Sink: print (1/1)#0] org.apache.kafka.common.utils.AppInfoParser - Kafka version: 3.4.0
11:40:16.300 INFO  [Source: TransactionSource -> Sink: print (1/1)#0] org.apache.kafka.common.utils.AppInfoParser - Kafka commitId: 2e1947d240607d53
11:40:16.300 INFO  [Source: TransactionSource -> Sink: print (1/1)#0] org.apache.kafka.common.utils.AppInfoParser - Kafka startTimeMs: 1721587216300
11:40:16.315 INFO  [Source Data Fetcher for Source: TransactionSource -> Sink: print (1/1)#0] o.a.f.c.base.source.reader.fetcher.SplitFetcher - Starting split fetcher 0
11:40:16.320 INFO  [Source Data Fetcher for Source: TransactionSource -> Sink: print (1/1)#0] org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer clientId=group.finance.transactions-0, groupId=group.finance.transactions] Assigned to partition(s): transactions-1, transactions-2, transactions-4, transactions-3, transactions-0
11:40:16.324 INFO  [Source Data Fetcher for Source: TransactionSource -> Sink: print (1/1)#0] o.a.k.clients.consumer.internals.SubscriptionState - [Consumer clientId=group.finance.transactions-0, groupId=group.finance.transactions] Seeking to earliest offset of partition transactions-1
11:40:16.325 INFO  [Source Data Fetcher for Source: TransactionSource -> Sink: print (1/1)#0] o.a.k.clients.consumer.internals.SubscriptionState - [Consumer clientId=group.finance.transactions-0, groupId=group.finance.transactions] Seeking to earliest offset of partition transactions-2
11:40:16.325 INFO  [Source Data Fetcher for Source: TransactionSource -> Sink: print (1/1)#0] o.a.k.clients.consumer.internals.SubscriptionState - [Consumer clientId=group.finance.transactions-0, groupId=group.finance.transactions] Seeking to earliest offset of partition transactions-4
11:40:16.325 INFO  [Source Data Fetcher for Source: TransactionSource -> Sink: print (1/1)#0] o.a.k.clients.consumer.internals.SubscriptionState - [Consumer clientId=group.finance.transactions-0, groupId=group.finance.transactions] Seeking to earliest offset of partition transactions-3
11:40:16.325 INFO  [Source Data Fetcher for Source: TransactionSource -> Sink: print (1/1)#0] o.a.k.clients.consumer.internals.SubscriptionState - [Consumer clientId=group.finance.transactions-0, groupId=group.finance.transactions] Seeking to earliest offset of partition transactions-0
11:40:16.359 INFO  [Source Data Fetcher for Source: TransactionSource -> Sink: print (1/1)#0] org.apache.kafka.clients.Metadata - [Consumer clientId=group.finance.transactions-0, groupId=group.finance.transactions] Cluster ID: redpanda.43adbc2c-7ca5-42b7-b367-06ff665df7e4
11:40:16.374 INFO  [Source Data Fetcher for Source: TransactionSource -> Sink: print (1/1)#0] o.a.k.clients.consumer.internals.SubscriptionState - [Consumer clientId=group.finance.transactions-0, groupId=group.finance.transactions] Resetting offset for partition transactions-3 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:19092 (id: 0 rack: null)], epoch=absent}}.
11:40:16.375 INFO  [Source Data Fetcher for Source: TransactionSource -> Sink: print (1/1)#0] o.a.k.clients.consumer.internals.SubscriptionState - [Consumer clientId=group.finance.transactions-0, groupId=group.finance.transactions] Resetting offset for partition transactions-4 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:19092 (id: 0 rack: null)], epoch=absent}}.
11:40:16.375 INFO  [Source Data Fetcher for Source: TransactionSource -> Sink: print (1/1)#0] o.a.k.clients.consumer.internals.SubscriptionState - [Consumer clientId=group.finance.transactions-0, groupId=group.finance.transactions] Resetting offset for partition transactions-1 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:19092 (id: 0 rack: null)], epoch=absent}}.
11:40:16.376 INFO  [Source Data Fetcher for Source: TransactionSource -> Sink: print (1/1)#0] o.a.k.clients.consumer.internals.SubscriptionState - [Consumer clientId=group.finance.transactions-0, groupId=group.finance.transactions] Resetting offset for partition transactions-2 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:19092 (id: 0 rack: null)], epoch=absent}}.
11:40:16.376 INFO  [Source Data Fetcher for Source: TransactionSource -> Sink: print (1/1)#0] o.a.k.clients.consumer.internals.SubscriptionState - [Consumer clientId=group.finance.transactions-0, groupId=group.finance.transactions] Resetting offset for partition transactions-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[localhost:19092 (id: 0 rack: null)], epoch=absent}}.