@@ -11,6 +11,10 @@ data:
bootstrap_servers => ["kafka-0.kafka-headless.pro.svc.cluster.local:9093,kafka-1.kafka-headless.pro.svc.cluster.local:9093,kafka-2.kafka-headless.pro.svc.cluster.local:9093"]
group_id => "es-test"
auto_offset_reset => "latest"
+ consumer_threads => 10
+ max_partition_fetch_bytes => 4194304
+ receive_buffer_bytes => 131072
+ send_buffer_bytes => 524288
topics => ["offline-process-topic"]
codec => json
}