如何从ZeroCode框架消费Kafka主题

Question

我想通过ZeroCode框架消费一个卡夫卡主题。我可以从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解决了我的问题。