Nebula Exchange3.0.0导入Kafka数据失败

[Endeavour]

我使用官网示例配置https://docs.nebula-graph.com.cn/3.1.0/nebula-exchange/use-exchange/ex-ug-import-from-kafka/向数据库导入Kafka中数据，抛出如下异常

查看对应位置源码发现hasKafka变量第一次循环就会变为true，这样下一次循环就一定会抛异常

看起来像是个bug，是不是应该改成下图这样

[steam]

代码判断上是这样的， 方便的话可以给我们提一个 pr 吗？我让负责的同学 review 下。

[Endeavour]

好的

[steam]

不不，你的代码和原来的代码是一个意思，你看 hasKafka 我们的代码默认是 false 的被你改成了 true，所以相对应的下面的就得改成 !hasKafka，所以原代码是逻辑没毛病的。

[sworduo]

因为kafka是流式数据，一旦开始了就会源源不断的产生和消费数据。所以一个exchange能且只能同时消费一个kafka数据源的数据。配置里加这个检查是提醒你，在kafka存在时，其他数据源都没用了。

[Endeavour]

比如说我要导入不同Tag的节点或者是不同的edge，就要起不同的exchange，是这样理解吧

[Endeavour]

我曲线救国了

[sworduo]

如果都是从kafka中解析，那就得一个tag/edge一个exchange了，你也可以自己改一改