Repository navigation
Failed to execute Consumer#getLastMessageId when setting brokerEntryMetadataInterceptors #10950
Description
Describe the bug
After setting brokerEntryMetadataInterceptors parameters in conf/broker.conf, we found that we cannot invoke method org.apache.pulsar.client.api.Consumer#getLastMessageId normally. At the same time, the log also prompted that an exception occurred during metadata parsing.
To Reproduce
Steps to reproduce the behavior:
- set parameters in
conf/broker.confas we used in KoP
# refer to https://github.com/streamnative/kop/blob/master/docs/kop.md
brokerEntryMetadataInterceptors=org.apache.pulsar.common.intercept.AppendIndexMetadataInterceptor,org.apache.pulsar.common.intercept.AppendBrokerTimestampMetadataInterceptor- execute a program like:
admin.topics().createNonPartitionedTopic(topic);
Producer<String> producer = pulsarClient.newProducer(Schema.STRING)
.topic(topic)
.create();
producer.newMessage().key("k1").value("mm").send();
Consumer<String> consumer = pulsarClient.newConsumer(Schema.STRING)
.topic(topic)
.subscriptionName(group)
.subscribe();
consumer.getLastMessageId();Expected behavior
Able to correctly execute Consumer#getLastMessageId in this scenario.
Screenshots
org.apache.pulsar.client.api.PulsarClientException$BrokerMetadataException:
The subscription XXX of the topic YYY gets the last message id was failed
Failed to get batch size for entry java.lang.IllegalArgumentException: Invalid unknonwn tag type: 6
at org.apache.pulsar.client.api.PulsarClientException.unwrap(PulsarClientException.java:987)
at org.apache.pulsar.client.impl.ConsumerBase.getLastMessageId(ConsumerBase.java:606)Additional context
I can help submit a PR later.
Activity