storm-kafka-client: 1.2.2 KafkaSpoutConfig с использованием Yaml - PullRequest
Новая
       24

storm-kafka-client: 1.2.2 KafkaSpoutConfig с использованием Yaml

0 голосов
/ 14 апреля 2019

Я пытаюсь настроить KafkaSpout через YAML и получаю следующее сообщение об ошибке

Исключение в потоке "main" java.lang.IllegalArgumentException: несоответствие типов аргументов

Ниже немного из моего файла YAML 

name: "SampleTopology"

components:
- id: "onlyValueRecordTranslator"
className: "org.apache.storm.kafka.spout.DefaultRecordTranslator"

- id: "spoutConfigBuilder"
  className: 
 "org.apache.storm.kafka.spout.KafkaSpoutConfig$Builder"
  constructorArgs:
  - "localhost:9092"
  - ["myKafkaTopic"]
  properties:
  - name: "firstPollOffsetStrategy"
    value: "LATEST"
  - name: "recordTranslator"
    ref: "onlyValueRecordTranslator"
 configMethods:
  - name: "setProp"
    args:
      - {
        "key.deserializer" : 
  "org.apache.kafka.common.serialization.StringDeserializer",
        "value.deserializer": 
  "org.apache.kafka.common.serialization.StringDeserializer"
      }


  - id: "spoutConfig"
  className: "org.apache.storm.kafka.spout.KafkaSpoutConfig"
  constructorArgs:
  - ref: "spoutConfigBuilder"

Может кто-нибудь указать мне какие-либо примеры использования KafkaSpoutConfig, хотя YAML?

Я использую следующие версии шторма икафка 

org.apache.storm:storm-core:1.2.2
org.apache.storm:storm-kafka-client:1.2.2
org.apache.storm', name: 'flux-core', version: '1.2.2

1 Ответ

1 голос
/ 15 апреля 2019

YAML выглядит правильно (предполагается, что поврежденный отступ является ошибкой копирования-вставки, в противном случае вам необходимо это исправить).

На вас влияет ошибка, исправленная в https://github.com/apache/storm/pull/2575. Itисправлено только в Storm 2.0.0, а не в ветках 1.x.Я не вижу причины, по которой мы не смогли сделать бэкпорт.

Код, который вы хотите перенести, это файл https://github.com/apache/storm/pull/2575/files#diff-472112e23a03ec30ae9c55beab542631. Не стесняйтесь открыть для него вопрос на https://issues.apache.org/jira.Если вы хотите работать над этим, вы можете отправить PR на https://github.com/apache/storm/pull.

...