diff --git a/src/main/java/com/microsoft/azure/functions/annotation/KafkaOutput.java b/src/main/java/com/microsoft/azure/functions/annotation/KafkaOutput.java index 2010abd..81cfa34 100644 --- a/src/main/java/com/microsoft/azure/functions/annotation/KafkaOutput.java +++ b/src/main/java/com/microsoft/azure/functions/annotation/KafkaOutput.java @@ -190,4 +190,12 @@ * @return The ssl key password. */ String sslKeyPassword() default ""; + + /** + * lingerMS property provides the time between batches of messages + * being sent to cluster. Larger value allows more batching results in high throughput. + * + * @return Linger.ms for librdkafka + */ + int lingerMs() default 5; }