Skip to content

Commit 29b0ed0

Browse files
committed
create a ceiling for the number of messages that can be received from the messages on a topic partition before publishing them to Pub/Sub
1 parent 6ee6eec commit 29b0ed0

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

broker/consumer/lsst/ps-connector.properties

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -37,3 +37,6 @@ cps.topic=PS_TOPIC
3737
cps.project=PROJECT_ID
3838
# include Kafka topic, partition, offset, timestamp as msg attributes
3939
metadata.publish=true
40+
# specify the maximum number of messages that can be received for the messages on a topic partition before publishing
41+
# them to Cloud Pub/Sub
42+
maxBufferSize=50

0 commit comments

Comments
 (0)