=== producer ===
property                                       kafka-clients default        set by Spring Boot          
--------------------------------------------------------------------------------------------------------
acks                                           all                          -                           
enable.idempotence                             true                         -                           
retries                                        2147483647                   -                           
max.in.flight.requests.per.connection          5                            -                           
linger.ms                                      5                            -                           
batch.size                                     16384                        -                           
compression.type                               none                         -                           
delivery.timeout.ms                            120000                       -                           

=== consumer ===
property                                       kafka-clients default        set by Spring Boot          
--------------------------------------------------------------------------------------------------------
auto.offset.reset                              latest                       earliest                    
enable.auto.commit                             true                         -                           
max.poll.records                               500                          -                           
max.poll.interval.ms                           300000                       -                           
session.timeout.ms                             45000                        -                           
heartbeat.interval.ms                          3000                         -                           
isolation.level                                read_uncommitted             read_uncommitted            
partition.assignment.strategy                  [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor] -                           

=== listener container ===
=== listener container ===
ackMode                                        BATCH
groupId                                        orders-basic
concurrency                                    
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 3.828 s -- in com.ankurm.kafkabasics.EffectiveConfigTest
[INFO] Running com.ankurm.kafkabasics.SerialisationTest
JacksonJsonSerializer -> {"orderId":"o-1","customerId":"c-1","amount":10.00,"placedAt":"2026-08-29T10:15:30Z"}
[INFO] Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.227 s -- in com.ankurm.kafkabasics.SerialisationTest
[INFO] Running com.ankurm.kafkabasics.KeysAndPartitionsTest
=== key -> partition, 3 partitions ===
key    partition   murmur2 & 0x7fffffff % 3 Math.abs(murmur2) % 3
o-1    0           0                        0
o-2    0           0                        2
o-3    1           1                        1
o-4    1           1                        1
o-5    2           2                        0
o-6    1           1                        1
2026-08-29T09:44:16.725+05:30  INFO 67 --- [kafka-basics] [ntainer#0-0-C-1] com.ankurm.kafkabasics.OrderConsumer     : received orderId=o-1 partition=0 offset=0
2026-08-29T09:44:16.726+05:30  INFO 67 --- [kafka-basics] [ntainer#0-0-C-1] com.ankurm.kafkabasics.OrderConsumer     : received orderId=o-2 partition=0 offset=1
2026-08-29T09:44:16.726+05:30  INFO 67 --- [kafka-basics] [ntainer#0-0-C-1] com.ankurm.kafkabasics.OrderConsumer     : received orderId=o-1 partition=0 offset=2
2026-08-29T09:44:16.726+05:30  INFO 67 --- [kafka-basics] [ntainer#0-0-C-1] com.ankurm.kafkabasics.OrderConsumer     : received orderId=o-3 partition=1 offset=0
2026-08-29T09:44:16.726+05:30  INFO 67 --- [kafka-basics] [ntainer#0-0-C-1] com.ankurm.kafkabasics.OrderConsumer     : received orderId=o-4 partition=1 offset=1
2026-08-29T09:44:16.727+05:30  INFO 67 --- [kafka-basics] [ntainer#0-0-C-1] com.ankurm.kafkabasics.OrderConsumer     : received orderId=o-6 partition=1 offset=2
2026-08-29T09:44:16.727+05:30  INFO 67 --- [kafka-basics] [ntainer#0-0-C-1] com.ankurm.kafkabasics.OrderConsumer     : received orderId=o-5 partition=2 offset=0
2026-08-29T09:44:16.746+05:30  INFO 67 --- [kafka-basics] [ntainer#0-0-C-1] com.ankurm.kafkabasics.OrderConsumer     : received orderId=e-1 partition=0 offset=3
2026-08-29T09:44:16.749+05:30  INFO 67 --- [kafka-basics] [ntainer#0-0-C-1] com.ankurm.kafkabasics.OrderConsumer     : received orderId=e-2 partition=1 offset=3
[INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.532 s -- in com.ankurm.kafkabasics.KeysAndPartitionsTest
[INFO] Running com.ankurm.kafkabasics.ManualAckTest
Bootstrap metadata: BootstrapMetadata(records=[ApiMessageAndVersion(FeatureLevelRecord(name='metadata.version', featureLevel=30) at version 0), ApiMessageAndVersion(FeatureLevelRecord(name='eligible.leader.replicas.version', featureLevel=1) at version 0), ApiMessageAndVersion(FeatureLevelRecord(name='group.version', featureLevel=1) at version 0), ApiMessageAndVersion(FeatureLevelRecord(name='share.version', featureLevel=1) at version 0), ApiMessageAndVersion(FeatureLevelRecord(name='streams.version', featureLevel=1) at version 0), ApiMessageAndVersion(FeatureLevelRecord(name='transaction.version', featureLevel=2) at version 0)], metadataVersionLevel=30, source=format command)
Formatting metadata directory /tmp/kafka-14668657738428164299/combined_0_0 with metadata.version 4.3-IV0.
2026-08-29T09:44:17.569+05:30  INFO 67 --- [kafka-basics] [           main] com.ankurm.kafkabasics.ManualAckTest     : Starting ManualAckTest using Java 25.0.4.1 with PID 67 (started by tender-adoring-cori in /tmp/work/smd/kafka-basics)
2026-08-29T09:44:17.570+05:30  INFO 67 --- [kafka-basics] [           main] com.ankurm.kafkabasics.ManualAckTest     : The following 1 profile is active: "test"
2026-08-29T09:44:17.780+05:30  INFO 67 --- [kafka-basics] [           main] com.ankurm.kafkabasics.ManualAckTest     : Started ManualAckTest in 0.503 seconds (process running for 6.368)
2026-08-29T09:44:18.617+05:30  INFO 67 --- [kafka-basics] [ntainer#0-0-C-1] com.ankurm.kafkabasics.OrderConsumer     : received orderId=o-1 partition=0 offset=0
[INFO] Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.919 s -- in com.ankurm.kafkabasics.ManualAckTest
[INFO] 
[INFO] Results:
[INFO] 
[INFO] Tests run: 8, Failures: 0, Errors: 0, Skipped: 0
[INFO] 
[INFO] ------------------------------------------------------------------------
[INFO] BUILD SUCCESS
[INFO] ------------------------------------------------------------------------
[INFO] Total time:  9.869 s
[INFO] Finished at: 2026-08-29T09:44:20+05:30
[INFO] ------------------------------------------------------------------------
