logstash消费kafka到es建立2个index数据一样

架构 elk kafka 版本全部7.2 系统centos7.3filebeat 取2个数据源1和2，把1的数据放到kafka，topic 1里2数据放在topic 2里
logstash建立两个配置文件到kafka分别消费数据1组里的topic1和2组里的topic2
logstash两个配置文件在es里分别建立1和2的index

问题是es里的1和2index数据都一样，index1里有2里的数据，2里也有1里的数据
 
我想实现的是es的index1里是1的数据，es的index2里是2的数据