Я хотел развернуть коннектор приемника S3 kafka (используя Apache Camel) в kubernetes, используя справочный документ https://ibm-cloud-architecture.github.io/refarch-eda/scenarios/connect-s3/ Заполнитель DateTime ( ${date:now:yyyyMMdd-HHmmssSSS}...

Я копирую свои темы kafka в s3 с помощью confluent kafka-connect-s3 https://www.confluent.io/hub/confluentinc/kafka-connect-s3 . Я хочу иметь возможность легко запрашивать эти данные с помощью Athena и правильно разбивать их для дешевого / быстрого...

У меня есть требование читать сериализованные сообщения JSON из темы Kafka, преобразовывать их в Parquet и сохранять в S3. Фон Официальный S3-Sink-Connector поддерживает формат вывода Parquet, но: Для этого соединителя необходимо...