kecona commented on code in PR #21311: URL: https://github.com/apache/pulsar/pull/21311#discussion_r1368296177
########## pip/pip-304.md: ########## @@ -0,0 +1,85 @@ +# Motivation + +We have a scenario that uses the `org.apache.pulsar.broker.intercept.BrokerInterceptor#messageProduced`, and need to +obtain the `org.apache.pulsar.common.api.proto.MessageMetadata`, but the `org.apache.pulsar.broker.service.Topic.PublishContext` doesn't provide this data. + +I will obtain the following data from the `org.apache.pulsar.common.api.proto.MessageMetadata`: + +- getPublishTime +- getEventTime +- getDeliverAtTime +- getPartitionKey + +# Goals + +## In Scope + +Make `org.apache.pulsar.broker.service.Topic.PublishContext` to provide the `org.apache.pulsar.common.api.proto.MessageMetadata`. Review Comment: > The headersAndPayload can be recycled after it has been written to bookies, don't need to wait for producer's receipt. I tried to parse the headersAndPayload in the `org.apache.pulsar.broker.service.Producer.MessagePublishContext#run`, and it works fine. If the headersAndPayload was recycled after it has been written to bookies, it means we can parse the headersAndPayload, is it right? -- 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: commits-unsubscr...@pulsar.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
