search

KonstantinCodes / messenger-kafka

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

Use the psr logger for log and error callbacks #73

Open andythorne opened 1 year ago

andythorne commented 1 year ago

By default rdkafka prints to stderr. With this change it will use the configured psr logger instead.

andythorne commented 1 year ago

@KonstantinCodes Are you able to take a look? 🙏

Arkemlar commented 1 year ago

Can you move callback definition code to separate method so it could be easaly overidded? Like it is done for createRebalanceCb