Jye-525 opened a new issue #7622:
URL: https://github.com/apache/pulsar/issues/7622
Hi,
I am making a comparison between Pulsar Functions and Kafka Streams. I
have several questions when using Pulsar Functions.
1) Before creating the Pulsar Functions, I already have a producer. It
generates 1000 messages to topic A. Then I start the Pulsar Functions to read
data from topic A and do some handling.
I want the Pulsar Functions could read the 1000 messages which has been
existed in topic A when Pulsar Functions starts. How to make the Pulsar
Functions to read data from the beginning of a topic?
2) Does Pulsar Functions use batching when reading data from the input
topics and sending data to output topic? How to change the batching parameters,
like BacthingMaxSize, BatchingMaxPublishDelay?
I am looking forward to your response.
Thank you very much
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
