@@ -68,30 +68,31 @@ Example of a default configuration:
68
68
``` properties
69
69
conductor.workflow-status-listener.type =kafka
70
70
71
- # Kafka Producer Configurations
72
- conductor.workflow-status-listener.kafka.producer. bootstrap.servers =kafka:29092
71
+ # Kafka Producer Configurations
72
+ conductor.workflow-status-listener.kafka.producer[ bootstrap.servers] =kafka:29092
73
73
74
- # Kafka Producer Configuration
75
- conductor.workflow-status-listener.kafka.producer. key.serializer =org.apache.kafka.common.serialization.StringSerializer
76
- conductor.workflow-status-listener.kafka.producer. value.serializer =org.apache.kafka.common.serialization.StringSerializer
74
+ # Serializers
75
+ conductor.workflow-status-listener.kafka.producer[ key.serializer] =org.apache.kafka.common.serialization.StringSerializer
76
+ conductor.workflow-status-listener.kafka.producer[ value.serializer] =org.apache.kafka.common.serialization.StringSerializer
77
77
78
78
# Reliability Settings
79
- conductor.workflow-status-listener.kafka.producer. acks =all
80
- conductor.workflow-status-listener.kafka.producer. enable.idempotence =true
79
+ conductor.workflow-status-listener.kafka.producer[ acks] =all
80
+ conductor.workflow-status-listener.kafka.producer[ enable.idempotence] =true
81
81
82
82
# Retry sending messages if failure
83
- conductor.workflow-status-listener.kafka.producer. retries =5
84
- conductor.workflow-status-listener.kafka.producer. retry.backoff.ms =100
83
+ conductor.workflow-status-listener.kafka.producer[ retries] =5
84
+ conductor.workflow-status-listener.kafka.producer[ retry.backoff.ms] =100
85
85
86
86
# Allow batching (default 0)
87
- conductor.workflow-status-listener.kafka.producer.linger.ms =10
88
- conductor.workflow-status-listener.kafka.producer.batch.size =65536
89
- conductor.workflow-status-listener.kafka.producer.buffer.memory =67108864
87
+ conductor.workflow-status-listener.kafka.producer[linger.ms]=10
88
+ conductor.workflow-status-listener.kafka.producer[batch.size]=65536
89
+ conductor.workflow-status-listener.kafka.producer[buffer.memory]=67108864
90
+
90
91
# Reduce network load
91
- conductor.workflow-status-listener.kafka.producer. compression.type =zstd
92
+ conductor.workflow-status-listener.kafka.producer[ compression.type] =zstd
92
93
93
94
# Allow multiple in-flight messages (better throughput)
94
- conductor.workflow-status-listener.kafka.producer. max.in.flight.requests.per.connection =1
95
+ conductor.workflow-status-listener.kafka.producer[ max.in.flight.requests.per.connection] =1
95
96
96
97
# Default Topic for All Workflow Status Events
97
98
conductor.workflow-status-listener.kafka.default-topic =workflow-status-events
0 commit comments