So far as I know, milvus doesn't specify any partition when creating consumer of kafka. I suppose it always uses the default/first partition.