为什么我的解决方案卡夫卡数据源卡住和/或不拉任何数据

Question

Kafta主题有消息，但Upsolver数据源被卡住或没有提取任何新消息。我们有大约15个这样的数据来源，有些正在正常工作，但有些似乎被困住了。这是怎么回事？

Answer 1

当Kafka数据源被创建时，就会有一个“从开始读”的配置。当为true (选中)时，Kafka DS只在数据源创建时在主题中有任何消息时才会提取数据。如果主题为空，则该数据源将陷入停滞状态。在这种情况下，应该在未选中属性的情况下创建数据源。然后数据源将开始从其创建的角度提取消息。

或者，在创建数据源之前，您可以先在主题中的每个模式中播放一个示例虚拟消息，然后使用Read = True创建数据源，如果您不能或不能在创建之前等待数据到达。