jet / FsKafka

Minimal F# wrappers for Confluent.Kafka+librdkafka.redist 1.x
https://github.com/jet/dotnet-templates
Apache License 2.0
88 stars 17 forks source link

Change broker to bootstrapServers #49

Closed bartelink closed 4 years ago

bartelink commented 4 years ago

The broker : Uri arg in the Producer and Consumer config wrappers currently constrain the bootstrapServers passed to a single entry. This obscures a core function of an idiomatic Kafka Client for a debatable reason

There is currently a workaround (which I didnt realize in advance of implementing this 😊) - supply a dummy value for broker and then stuff in a custom bootstrapServers value via custom

I may consider deferring the merging of this until 2.0.0 depending on what folks think

If anyone has any insights like e.g. telling me that in practice bootstrapServers are never usefully >1 therefore this makes no sense, let me know too!

This will also flow through to the parallel implementation contained in https://github.com/jet/propulsion/tree/master/src/Propulsion.Kafka0