diff --git a/src/MinimalKafka/KafkaProducerFactory.cs b/src/MinimalKafka/KafkaProducerFactory.cs index 2371256..1ed22f9 100644 --- a/src/MinimalKafka/KafkaProducerFactory.cs +++ b/src/MinimalKafka/KafkaProducerFactory.cs @@ -18,17 +18,18 @@ internal class KafkaProducerFactory : IProducer public KafkaProducerFactory(IKafkaBuilder builder) { - var config = builder.MetaData.OfType().First(); + var c = builder.MetaData.OfType().FirstOrDefault()?.Configuration; var keySerializer = builder.MetaData.OfType().First(); var valueSerializer = builder.MetaData.OfType().First(); - var producerConfig = new ProducerConfig(config.Configuration); + + ProducerConfig config = c is null ? new() : new(c); _topicFormatter = builder.MetaData.OfType().First(); var serializerKey = ActivatorUtilities.CreateInstance(builder.ServiceProvider, keySerializer.GetSerializerType()); var serializerValue = ActivatorUtilities.CreateInstance(builder.ServiceProvider, valueSerializer.GetSerializerType()); - Producer = new ProducerBuilder(producerConfig) + Producer = new ProducerBuilder(config) .SetKeySerializer((ISerializer)serializerKey) .SetValueSerializer((ISerializer)serializerValue) .Build();