Оптимальная конфигурация подключения Kakfa Ежечасно S3AvroSink

#apache-kafka #apache-kafka-connect #s3-kafka-connector Вопрос: { "name":"{{name}}", "tasks.max": "6", //have 6 partitions for this topic "topics": "{{topic}}", "connector.class": "io.confluent.connect.s3.S3SinkConnector", "key.converter": "io.confluent.connect.avro.AvroConverter", "key.converter.schemas.enable": "true", "key.converter.schema.registry.url": "xx", "key.converter.key.subject.name.strategy": "io.confluent.kafka.serializers.subject.TopicRecordNameStrategy", "value.converter": "io.confluent.connect.avro.AvroConverter", "value.converter.schemas.enable": "true",…