You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "ShivsundarR (via GitHub)" <gi...@apache.org> on 2025/04/11 10:39:10 UTC
[PR] MINOR: Update kafka-console-share-consumer to pass in delivery count. [kafka]
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-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] MINOR: Update kafka-console-share-consumer to pass in delivery count. [kafka]
Posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org>.
AndrewJSchofield merged PR #19447:
URL: https://github.com/apache/kafka/pull/19447
--
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-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org