Reputation: 1342
I am using Kafka-Influxdb connector and for now, It is enough for me to refresh the Kafka topic in a 1-minute interval but I can't find any option to change the refresh time
Upvotes: 0
Views: 132
Reputation: 4375
If you want to override producer properties (linger.ms
in your case) for a specific connector, enable client overrides in the worker configuration and then use producer.override.*
for a source connector config:
"producer.override.linger.ms": "0"
Source: Kafka Connect Worker Configuration Properties: Override the Worker Configuration
Upvotes: 1