Kafka Producer and Consumer API

Hi,

Please, help to resolve my issue.

getting while starting in consumer, i am looking below error, please help to check what needs to do,

2024-02-18T16:03:48.449+05:30 INFO 19332 — [ main] o.a.kafka.common.utils.AppInfoParser : Kafka version: 3.6.1
2024-02-18T16:03:48.452+05:30 INFO 19332 — [ main] o.a.kafka.common.utils.AppInfoParser : Kafka commitId: 5e3c2b738d253ff5
2024-02-18T16:03:48.452+05:30 INFO 19332 — [ main] o.a.kafka.common.utils.AppInfoParser : Kafka startTimeMs: 1708252428446
2024-02-18T16:03:48.461+05:30 INFO 19332 — [ main] fkaConsumerFactory$ExtendedKafkaConsumer : [Consumer clientId=consumer-test-group-1, groupId=test-group] Subscribed to topic(s): checkdata
2024-02-18T16:03:48.500+05:30 INFO 19332 — [ main] S.SalesOrderConsumerApplication : Started SalesOrderConsumerApplication in 2.583 seconds (process running for 2.943)
2024-02-18T16:03:49.134+05:30 INFO 19332 — [ntainer#0-0-C-1] org.apache.kafka.clients.Metadata : [Consumer clientId=consumer-test-group-1, groupId=test-group] Cluster ID: T98ZhSHIQmqxLjx5cCcCXw
2024-02-18T16:03:49.135+05:30 INFO 19332 — [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-test-group-1, groupId=test-group] Discovered group coordinator 127.0.0.1:9092 (id: 2147483647 rack: null)
2024-02-18T16:03:49.138+05:30 INFO 19332 — [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-test-group-1, groupId=test-group] (Re-)joining group
2024-02-18T16:03:49.152+05:30 INFO 19332 — [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-test-group-1, groupId=test-group] Request joining group due to: need to re-join with the given member-id: consumer-test-group-1-d7b9dffc-6a53-4613-9893-a97d4f2fa268
2024-02-18T16:03:49.153+05:30 INFO 19332 — [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-test-group-1, groupId=test-group] Request joining group due to: rebalance failed due to ‘The group member needs to have a valid member id before actually entering a consumer group.’ (MemberIdRequiredException)
2024-02-18T16:03:49.153+05:30 INFO 19332 — [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-test-group-1, groupId=test-group] (Re-)joining group
2024-02-18T16:03:49.157+05:30 INFO 19332 — [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-test-group-1, groupId=test-group] Successfully joined group with generation Generation{generationId=10, memberId=‘consumer-test-group-1-d7b9dffc-6a53-4613-9893-a97d4f2fa268’, protocol=‘range’}
2024-02-18T16:03:49.165+05:30 INFO 19332 — [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-test-group-1, groupId=test-group] Finished assignment for group at generation 10: {consumer-test-group-1-d7b9dffc-6a53-4613-9893-a97d4f2fa268=Assignment(partitions=[checkdata-0, checkdata-1, checkdata-2, checkdata-3, checkdata-4])}
2024-02-18T16:03:49.174+05:30 INFO 19332 — [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-test-group-1, groupId=test-group] Successfully synced group in generation Generation{generationId=10, memberId=‘consumer-test-group-1-d7b9dffc-6a53-4613-9893-a97d4f2fa268’, protocol=‘range’}
2024-02-18T16:03:49.175+05:30 INFO 19332 — [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-test-group-1, groupId=test-group] Notifying assignor about the new Assignment(partitions=[checkdata-0, checkdata-1, checkdata-2, checkdata-3, checkdata-4])
2024-02-18T16:03:49.178+05:30 INFO 19332 — [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-test-group-1, groupId=test-group] Adding newly assigned partitions: checkdata-0, checkdata-1, checkdata-2, checkdata-3, checkdata-4
2024-02-18T16:03:49.185+05:30 INFO 19332 — [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-test-group-1, groupId=test-group] Found no committed offset for partition checkdata-4
2024-02-18T16:03:49.186+05:30 INFO 19332 — [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-test-group-1, groupId=test-group] Found no committed offset for partition checkdata-2
2024-02-18T16:03:49.186+05:30 INFO 19332 — [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-test-group-1, groupId=test-group] Found no committed offset for partition checkdata-3
2024-02-18T16:03:49.187+05:30 INFO 19332 — [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-test-group-1, groupId=test-group] Found no committed offset for partition checkdata-0
2024-02-18T16:03:49.187+05:30 INFO 19332 — [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-test-group-1, groupId=test-group] Found no committed offset for partition checkdata-1
2024-02-18T16:03:49.194+05:30 INFO 19332 — [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-test-group-1, groupId=test-group] Found no committed offset for partition checkdata-4
2024-02-18T16:03:49.194+05:30 INFO 19332 — [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-test-group-1, groupId=test-group] Found no committed offset for partition checkdata-2
2024-02-18T16:03:49.194+05:30 INFO 19332 — [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-test-group-1, groupId=test-group] Found no committed offset for partition checkdata-3
2024-02-18T16:03:49.194+05:30 INFO 19332 — [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-test-group-1, groupId=test-group] Found no committed offset for partition checkdata-0
2024-02-18T16:03:49.194+05:30 INFO 19332 — [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-test-group-1, groupId=test-group] Found no committed offset for partition checkdata-1
2024-02-18T16:03:49.206+05:30 INFO 19332 — [ntainer#0-0-C-1] o.a.k.c.c.internals.SubscriptionState : [Consumer clientId=consumer-test-group-1, groupId=test-group] Resetting offset for partition checkdata-4 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[127.0.0.1:9092 (id: 0 rack: null)], epoch=0}}.
2024-02-18T16:03:49.208+05:30 INFO 19332 — [ntainer#0-0-C-1] o.a.k.c.c.internals.SubscriptionState : [Consumer clientId=consumer-test-group-1, groupId=test-group] Resetting offset for partition checkdata-2 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[127.0.0.1:9092 (id: 0 rack: null)], epoch=0}}.
2024-02-18T16:03:49.208+05:30 INFO 19332 — [ntainer#0-0-C-1] o.a.k.c.c.internals.SubscriptionState : [Consumer clientId=consumer-test-group-1, groupId=test-group] Resetting offset for partition checkdata-3 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[127.0.0.1:9092 (id: 0 rack: null)], epoch=0}}.
2024-02-18T16:03:49.208+05:30 INFO 19332 — [ntainer#0-0-C-1] o.a.k.c.c.internals.SubscriptionState : [Consumer clientId=consumer-test-group-1, groupId=test-group] Resetting offset for partition checkdata-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[127.0.0.1:9092 (id: 0 rack: null)], epoch=0}}.
2024-02-18T16:03:49.208+05:30 INFO 19332 — [ntainer#0-0-C-1] o.a.k.c.c.internals.SubscriptionState : [Consumer clientId=consumer-test-group-1, groupId=test-group] Resetting offset for partition checkdata-1 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[127.0.0.1:9092 (id: 0 rack: null)], epoch=0}}.
2024-02-18T16:03:49.215+05:30 INFO 19332 — [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : test-group: partitions assigned: [checkdata-0, checkdata-1, checkdata-2, checkdata-3, checkdata-4]

I don’t see any error. Only INFO logs.

Also, this question should be posted in Java Clients - Confluent Community, not here in “Kafka Streams” which is about, well, Kafka Streams (Apache Kafka) but not about producer/consumer.