LGouellec / kafka-streams-dotnet

.NET Stream Processing Library for Apache Kafka 🚀
https://lgouellec.github.io/kafka-streams-dotnet/
MIT License
453 stars 73 forks source link

Configuration : Allow override for external consumer/producer #244

Closed LGouellec closed 7 months ago

LGouellec commented 1 year ago

Description

For now, you can't override the configuration for external consumer and producer in the external stream thread. The aim of this feature is to purpose a new prefix configuration to override the fetch.min.bytes just for the external consumer for instance.

var config = new StreamConfig();
config.Add("external.consumer.fetch.min.bytes", 1000);
config.Add("external.producer.acks", Acks.Leader);