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
