Missing (Fixing) unit test for FeatureRowKafkaIO

[baskaranz]

Encountering the below issue when trying to run the unit test for FeatureRowKafkaIO

15:12:04 [direct-runner-worker] INFO  org.apache.kafka.common.utils.AppInfoParser - Kafka version : 2.0.0
15:12:04 [direct-runner-worker] INFO  org.apache.kafka.common.utils.AppInfoParser - Kafka commitId : 3402a8361b734732
15:12:04 [direct-runner-worker] INFO  org.apache.kafka.clients.Metadata - Cluster ID: BsCMKXsURGy8qHivvUcsFg
15:12:04 [direct-runner-worker] INFO  o.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-3, groupId=Reader-0_offset_consumer_1743545037_none] Resetting offset for partition test_topic-0 to offset 1.
15:12:04 [pool-13-thread-1] INFO  o.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-3, groupId=Reader-0_offset_consumer_1743545037_none] Resetting offset for partition test_topic-0 to offset 1.
15:12:05 [pool-13-thread-1] INFO  o.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-3, groupId=Reader-0_offset_consumer_1743545037_none] Resetting offset for partition test_topic-0 to offset 1.
15:12:06 [pool-13-thread-1] INFO  o.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-3, groupId=Reader-0_offset_consumer_1743545037_none] Resetting offset for partition test_topic-0 to offset 1.
15:12:07 [pool-13-thread-1] INFO  o.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-3, groupId=Reader-0_offset_consumer_1743545037_none] Resetting offset for partition test_topic-0 to offset 1.
15:12:08 [pool-13-thread-1] INFO  o.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-3, groupId=Reader-0_offset_consumer_1743545037_none] Resetting offset for partition test_topic-0 to offset 1.
15:12:09 [pool-13-thread-1] INFO  o.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-3, groupId=Reader-0_offset_consumer_1743545037_none] Resetting offset for partition test_topic-0 to offset 1.
15:12:10 [pool-13-thread-1] INFO  o.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-3, groupId=Reader-0_offset_consumer_1743545037_none] Resetting offset for partition test_topic-0 to offset 1.

The test just keep on running in an endless loop looging the above.