smjn commented on PR #22479:
URL: https://github.com/apache/kafka/pull/22479#issuecomment-4626633061
### Sample output
```
$ bin/kafka-features.sh --bootstrap-server localhost:9092 upgrade --feature
share.version=2
share.version was upgraded to 2.
$ bin/kafka-configs.sh --bootstrap-server localhost:9092 --alter
--add-config "share.auto.offset.reset=earliest" --entity-type groups
--entity-name gs1
Completed updating config for group gs1.
$ bin/kafka-configs.sh --bootstrap-server localhost:9092 --alter
--add-config "errors.deadletterqueue.topic.name=dlq.gs1dlqtopic" --entity-type
groups --entity-name gs1
Completed updating config for group gs1.
$ bin/kafka-configs.sh --bootstrap-server localhost:9092 --alter
--add-config "errors.deadletterqueue.copy.record.enable=true" --entity-type
groups --entity-name gs1
Completed updating config for group gs1.
$ bin/kafka-topics.sh --bootstrap-server localhost:9092 --create --topic t1
Created topic t1.
$ bin/kafka-producer-perf-test.sh --bootstrap-server localhost:9092 --topic
t1 --num-records 5 --payload-monotonic --throughput -1
5 records sent, 15.723270 records/sec (0.00 MB/sec), 180.80 ms avg latency,
308.00 ms max latency, 149 ms 50th, 308 ms 95th, 308 ms 99th, 308 ms 99.9th.
$ bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic
dlq.gs1dlqtopic --from-beginning --property print.key=true --property
print.headers=true --property print.partition=true --property
print.timestamp=true --timeout-ms 6000
Option --property is deprecated and will be removed in a future version. Use
--formatter-property instead.
The consumer rebalance protocol (KIP-848) is production-ready! Set
group.protocol=consumer to try it out. See
https://kafka.apache.org/documentation/#consumer_rebalance_protocol
CreateTime:491928092 Partition:0
__dlq.errors.topic:t1,__dlq.errors.partition:0,__dlq.errors.offset:0,__dlq.errors.group:gs1,__dlq.errors.delivery.count:1,__dlq.errors.message:Offset
rejected by client. null 0
CreateTime:491928092 Partition:0
__dlq.errors.topic:t1,__dlq.errors.partition:0,__dlq.errors.offset:1,__dlq.errors.group:gs1,__dlq.errors.delivery.count:1,__dlq.errors.message:Offset
rejected by client. null 1
CreateTime:491928092 Partition:0
__dlq.errors.topic:t1,__dlq.errors.partition:0,__dlq.errors.offset:2,__dlq.errors.group:gs1,__dlq.errors.delivery.count:1,__dlq.errors.message:Offset
rejected by client. null 2
CreateTime:491928092 Partition:0
__dlq.errors.topic:t1,__dlq.errors.partition:0,__dlq.errors.offset:3,__dlq.errors.group:gs1,__dlq.errors.delivery.count:1,__dlq.errors.message:Offset
rejected by client. null 3
CreateTime:491928092 Partition:0
__dlq.errors.topic:t1,__dlq.errors.partition:0,__dlq.errors.offset:4,__dlq.errors.group:gs1,__dlq.errors.delivery.count:1,__dlq.errors.message:Offset
rejected by client. null 4
```
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
