Можно ли использовать Confluent Schema Registry бесплатно?

Недавно начали использовать Confluent Kafka + KSQL + Confluent Schema Registry + Confluent Avro Converter. В итоге, возник вопрос можно ли использовать SR и Confluent Avro в рамках компании бесплатно или же нужно как-то приобретать лицензию. Почитали документы, но не нашли конкретный ответ.

Изначально организовал перелив из mysql в mssql через apacheKafka + KSQL, но насколько я понимаю для нормальной работы ksql нужен реестр схем и лучше использовать Avro Converter. Поэтому перешел на стэк Confluent Platform Comunity.

ИТОГО:

  1. Confluent Platform Community платная ? Если да, то существуют ли бесплатные способы организовать реестр схем ?
  2. Можно ли для преобразования данных обойтись силами apache kafka + KSQL ?

На всякий случай, часть конфигурации коннекторов:

SOURCE Connector:

 {
"name": "source-connector",
        "config": {
    
                "include.schema.changes": "false",
        
                "snapshot.mode": "SCHEMA_ONLY_RECOVERY",
                "snapshot.locking.mode": "minimal_percona",
        
                "transforms": "unwrap, extractKey",
        
                "transforms.unwrap.type": "io.debezium.transforms.ExtractNewRecordState",
                "transforms.unwrap.drop.tombstones": "false",
        
                "transforms.extractKey.type" :"org.apache.kafka.connect.transforms.ExtractField$Key",
                "transforms.extractKey.field" : "id",
        
                "key.converter": "org.apache.kafka.connect.storage.StringConverter",
        
                "value.converter":"io.confluent.connect.avro.AvroConverter",
                "value.converter.schema.registry.url":"http://localhost:8081",
                "name": "source-connector"
                }
    

SINK Connector:

{
"name" : "sink-connector",
"config" : {
    
"key.converter": "org.apache.kafka.connect.storage.StringConverter",
"value.converter":"io.confluent.connect.avro.AvroConverter",
"value.converter.schema.registry.url":"http://localhost:8081",
   
"insert.mode" : "upsert",
"delete.enabled": "true",

"pk.mode" : "record_key",
"pk.fields" : "id",

"auto.create" : "true",
"auto.evolve" : "true",

"name" : "sink-connector"
        }

Ответы (0 шт):