Какая будет конфигурация, когда весенний облачный поток kafka отправит объект Flink Kafka Consumer - PullRequest
Новая
       66

Какая будет конфигурация, когда весенний облачный поток kafka отправит объект Flink Kafka Consumer

0 голосов
/ 30 августа 2018

Привет! Я пытаюсь создать данные для темы kafka с помощью облачного потока Spring, но не могу их использовать, пока пользуюсь службой Flink. ниже мой код:

Конфигурация Spring Cloud Kafka: 

spring:
  cloud:
    stream:
      kafka:
        binder:
          brokers: #
          zk-nodes: #
      bindings:
        temp-target-feature-output:
          destination: someTopic
          group: test1

код производителя: 

messageChannel.send(MessageBuilder.withPayload(data).build());

FlinkkafkaConsumer: 

DataStream<ObjectNode> initialStreamData = env.addSource(new 
FlinkKafkaConsumer09<>("someTopic", new JSONDeserializationSchema(), 
kafkaConsumerProps));
    initialStreamData.print();

При использовании Spring Cloud Kafka Consumer я могу потреблять, но Flinkconsumer не может потреблять. Я предполагаю кое-что, что нам нужно настроить в весеннем облачном потоке.

...