You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@pulsar.apache.org by Jie Ye <jy...@hawk.iit.edu.INVALID> on 2020/07/21 02:33:26 UTC

Questions about using Pulsar Functions

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