Я использовал этот URL для создания коннектора раковины Kinesis в kafka:
https://github.com/awslabs/kinesis-kafka-connector/blob/master/config/kinesis-streams-kafka-connector.properties.
Между тем, я использую разъем источника импульсного файла, чтобы сканировать файлы и передавать их на Kafka, с Kafka на AWS Kinesis и, наконец, в корзину s3.
Моя установка работает нормально , Я вижу данные в формате JSON в Kafka, а также вижу всплеск на панели мониторинга Kinesis.
Поток данных Kinesis в порядке. Но файлы не загружаются в корзину S3. Я проверил, нет проблемы с доступом. Я предоставил администратору, а также S3 полный доступ к Kinesis.
Я что-то упустил в конфигурации S3 bucket? Что может быть причиной? Любые предложения приветствуются.