mirror of https://github.com/milvus-io/milvus.git
b6fefee0cf
Fix etcd config source didn't respect auth enabled Also removed pulsar recoverable error when pulsar return ConsumerBusy. It could happen that pulsar didn't find the original consumer is dead and recover takes some time. fix #31631 Signed-off-by: xiaofanluan <xiaofan.luan@zilliz.com> |
||
|---|---|---|
| .. | ||
| kafka | ||
| nmq | ||
| pulsar | ||
| client.go | ||
| consumer.go | ||
| id.go | ||
| message.go | ||
| mock_id.go | ||
| producer.go | ||