search

KonstantinCodes / messenger-kafka

Simple Kafka transport for Symfony Messenger.
MIT License
84 stars 35 forks source link

Support for options in DSN #83

Open devnix opened 5 months ago

devnix commented 5 months ago

For example: 

kafka://host1:9092?commitAsync=true&receiveTimeout=10000&topic[name]=events&kafka_conf[enable.auto.offset.store]=true&kafka_conf[group.id]=my-group-id&kafka_conf[max.poll.interval.ms]=45000&topic_conf[auto.offset.reset]=earliest,kafka://host2:9092?commitAsync=true&receiveTimeout=10000&topic[name]=events&kafka_conf[enable.auto.offset.store]=true&kafka_conf[group.id]=my-group-id&kafka_conf[max.poll.interval.ms]=45000&topic_conf[auto.offset.reset]=earliest