Конфигурация производителя Микронавт Кинезис - PullRequest
Новая
       35

Конфигурация производителя Микронавт Кинезис

0 голосов
/ 25 марта 2020

Я пытаюсь интегрировать Kinesis в приложение Micronaut. Я смог настроить Consumer. Если я отправляю данные в Kinesis Data Stream из какого-либо другого приложения, потребитель читает их. Итак, я знаю, что конфигурация потока данных Kinesis в порядке.

Я создал конечную точку, которую я запускаю для отправки данных в источник. Производитель - класс KinesisProducer. java с аннотацией @KinesisClient. У него есть один метод с именем putRecordBytes. Когда я проверяю логи, ошибок нет. Конечная точка вызывает класс Producer, все журналы из метода putRecordBytes есть, но на самом деле ничего не отправляется в поток Kinesis.

Это моя конфигурация источника в serverless.yaml 

kinesisProducer:
handler: my.package.KinesisProducer::putRecordBytes
events:
  - stream:
      type: kinesis
      batchSize: 1
      arn: arn:aws:kinesis:region:XXXXXX:stream/my-kinesis-stream
      enabled: true

Что такое Я пропал?

...