Commit b3b41de
committed
feat: introduce async Kafka adapters and enhance existing interfaces
- Added AsyncKafkaConsumerPort and AsyncKafkaProducerPort interfaces for asynchronous operations.
- Implemented AsyncKafkaConsumerAdapter and AsyncKafkaProducerAdapter classes to support async message consumption and production.
- Updated KafkaConsumerAdapter and KafkaProducerAdapter to include close methods for proper resource management.
- Enhanced KafkaConfig with new settings for async adapters, including worker threads and buffer timeout.
- Updated feature tests to include scenarios for async operations, ensuring comprehensive coverage of new functionality.1 parent 0969216 commit b3b41de
5 files changed
Lines changed: 1117 additions & 63 deletions
File tree
- archipy
- adapters/kafka
- configs
- features
- steps
0 commit comments