issues
search
bmoscon
/
cryptofeed
Cryptocurrency Exchange Websocket Data Feed Handler
Other
2.14k
stars
668
forks
source link
Kafka enhancements
#939
Closed
peedrr
closed
1 year ago
peedrr
commented
1 year ago
This PR adds two new features:
All
AIOKafkaProducer
configuration options are now accessible by passing kwargs to the backend callback
Kafka backend now uses
BackendQueue
with immediate 'sends', reliable reconnects and cleanup on shutdown.
[X] - Tested
[X] - Changelog updated
[X] - Tests run and pass
[X] - Flake8 run and all errors/warnings resolved
[ ] - Contributors file updated (optional)
This PR adds two new features:
AIOKafkaProducerconfiguration options are now accessible by passing kwargs to the backend callbackBackendQueuewith immediate 'sends', reliable reconnects and cleanup on shutdown.