如何从 ZeroCode 框架中使用 Kafka 主题

Question

我想通过 ZeroCode 框架使用一个 kafka 主题。我可以从 ZeroCode 场景中使用我的本地 kafka 服务器。我也可以通过命令行使用 kafka-consumer.bat 来使用从我的实际远程 kafka 服务器获取的主题，但我不能从 ZeroCode 中使用相同的主题。

我需要添加什么特殊配置？

{ 
  "name": "Consume Message From doob-ship-topic",
  "url": "kafka-topic:my-sample-topic",
  "operation": "consume",
  "request": {
    "consumerLocalConfigs": {
      "recordType": "JSON",
      "commitSync": false,
      "showRecordsConsumed": true,
      "maxNoOfRetryPollsOrTimeouts": 3
    }
  },
  "assertions": {
    "size": 1,
    "records": [
      {
        "value": {
          "key": "99930000000000260001"
        }
      }
    ]
  }
}

我尝试了不同的配置，但我没有处理。

Answer 1

我解决了。

    "consumerLocalConfigs": {
      "recordType": "RAW",
      "commitSync": true,
      "showRecordsConsumed": true,
      "maxNoOfRetryPollsOrTimeouts": 2,
      "pollingTime": 1595  // I added this.
    }

添加 pollingTime 解决了我的问题。