Current state: Accepted
ISSUE: https://github.com/milvus-io/milvus/issues/5218
PRs:
Keywords: Kafka
Released: with Milvus 2.1
Authors:
Summary
Milvus supports kafka and provides a configuration option to use pulsar, kafka and rocksmq.
Motivation
Kafka has more users and better stability.
Design Details
- add kafka and zookepper dev docker
- optimization mq_factory configuration initialization
- remove reader
- implement msg_stream with kafka
Test Plan
- pass the unittest
- performance testing