You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Thanks for raising the issue, I think this could be worth implementing, though it would be an enhancement since the properties can always be overwritten from the config class.
The purpose of the properties config is to provide extra properties that are not captured by the config class , however most of the common used ones are already explicitly defined. Could tell what extra properties were you trying to add?
When you set KafkaConsumerConfig(source= someTypesafeConfig) you would expect that the configs that are not explicitly set by monix KafkaConsumerConfig would get passed onto properties, but that is not the case as it is being set to
properties = Map.empty
:https://github.com/monix/monix-kafka/blob/master/kafka-0.11.x/src/main/scala/monix/kafka/KafkaConsumerConfig.scala#L439
Similarly with KafkaProducerConfig.
The text was updated successfully, but these errors were encountered: