ShivsundarR opened a new pull request, #19447:
URL: https://github.com/apache/kafka/pull/19447
*What*
- There was a bug in `ConsoleShareConsumer` where the delivery count
received in the `ShareFetchResponse` was not sent to the formatter to be shown
to the user. PR fixes the bug by passing in the delivery count in a different
constructor for `ConsumerRecord`.
-
- Added unit test to verify the change.
- Tested using the kafka-console-share-consumer.sh tool as well.
```
➜ kafka git:(minor-fix-console-share-consumer) ✗
bin/kafka-console-share-consumer.sh --bootstrap-server localhost:9092 --topic
T1 --property print.offset=true --property print.delivery=true
[2025-04-11 16:05:42,824] WARN Share groups and KafkaShareConsumer are part
of the early access of KIP-932 and MUST NOT be used in production.
(org.apache.kafka.clients.consumer.internals.ShareConsumerDelegateCreator)
[2025-04-11 16:05:43,009] WARN [ShareConsumer
clientId=console-share-consumer, groupId=console-share-consumer] The metadata
response from the cluster reported a recoverable issue with correlation id 28 :
{T1=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
Offset:0 Delivery:1 1
Offset:1 Delivery:1 2
Offset:2 Delivery:1 3
Offset:3 Delivery:1 4
Offset:4 Delivery:1 5
Offset:5 Delivery:1 6
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
