Configurações avançadas do Kafka

Propriedades do usuário

Forneça definições de configuração opcionais atualizando seu arquivo user.properties .

spring.profiles.active

Padrão: local

O Relational Migrator pode ser executado nos seguintes perfis:

• kafka: Servidor remoto usando sistema de servidor incorporado.

• confluent: servidor remoto usando o Confluent Cloud para Kafka gerenciado.

server.port

Padrão: 8278

A porta em que o aplicação Relational Migrator é executado.

migrator.kafka.bootstrap.servers

Uma lista de host:port pares do seu Kafka cluster preexistente.

Por exemplo: kafka-1:9092, kafka-2:9093.

Para obter mais informações, consulte Propriedades de configuração do trabalhador .

migrator.kafka.connect.url

O URL do host do Kafka Connect usando o formato host:port .

Por exemplo: https://localhost:8083.

migrator.kafka.connect.metrics.jmx.service.url

O URL do Kafka Connect Java Management Extensions (JMX).

migrator.kafka.connect.metrics.jmx.ssl

Padrão: false

Defina como true se o SSL estiver ativado.

Você pode adicionar extensões de gerenciamento Java (JMX) adicionais para configurações SSL prefixando-as com migrator.kafka.connect.metrics.jmx.properties.

migrator.kafka.enable.topic.cleanup

Padrão: false

Limpa os tópicos criados durante a última tarefa de migração.

migrator.connector.source.common.errors.max.retries

Padrão: 5

Para o connector de origem, ele especifica o número máximo de tentativas em uma falha recuperável. O Relational Migrator tenta a recuperação de falhas recuperáveis do banco de dados de origem até um limite definido antes que a tarefa falhe.

migrator.connector.source.common.errors.retry.initial.max.ms

Padrão: 30000 ms

Para o conector de origem, ele especifica o atraso em milissegundos para iniciar novamente após uma falha recuperável. O valor dobra a cada nova tentativa, mas não excede migrator.connector.source.common.errors.retry.delay.max.ms.

migrator.connector.source.common.errors.retry.delay.max.ms

Padrão: 60000 ms

Para o conector de origem, ele especifica o atraso máximo em milissegundos entre as novas tentativas após uma falha recuperável.

migrator.connector.sink.common.errors.max.retries

Padrão: 5

Para o connector de pia , ele especifica o número máximo de tentativas em uma falha recuperável. O Relational Migrator tenta a recuperação de falhas recuperáveis do banco de dados de origem até um limite definido antes que a tarefa falhe.

migrator.connector.sink.common.errors.retry.initial.max.ms

Padrão: 30000 ms

Para o conector de pia, ele especifica o atraso em milissegundos para iniciar novamente após uma falha recuperável. O valor dobra a cada nova tentativa, mas não excede migrator.connector.sink.common.errors.retry.delay.max.ms.

migrator.connector.sink.common.errors.retry.delay.max.ms

Padrão: 60000 ms

Para o conector de pia, ele especifica o atraso máximo em milissegundos entre as novas tentativas após uma falha recuperável.

Propriedades do registro de esquema

Use o Relational Migrator com qualquer registro de esquema adicionando propriedades ao arquivo user.properties com o prefixo migrator.connector.properties.common.

migrator.connector.properties.common.key.converter

Padrão: migrator.connector.properties.common.key.converter

A classe do conversor para a chave de mensagem.

migrator.connector.properties.common.value.converter

Padrão: org.apache.kafka.connect.json.JsonConverter

A classe do conversor para o valor da mensagem.

migrator.connector.properties.common.key.converter.apicurio.registry.url

Isto especifica o URL do Registo Apicurio para o conversor de chave.

Usa o formato http://{host}:{port} ou https://{host}:{port} .

migrator.connector.properties.common.value.converter.apicurio.registry.url

Isto especifica a URL do Registro Apicurio para o conversor de valor.

Usa o formato http://{host}:{port} ou https://{host}:{port} .

Propriedades connector de origem

Relational Migrator define propriedades padrão do conector de origem do Debezium para cada banco de banco de dados de origem suportada . As propriedades do conector podem ser substituídas adicionando-as no arquivo user.properties com o prefixo migrator.connector.source.common. Por exemplo:

migrator.connector.source.common.errors.max.retries: 0

Neste exemplo, o valor padrão é cinco, mas agora foi definido como zero. Isso significa que não há novas tentativas após uma falha recuperável.

Propriedades do Connector do coletor

O Relational Migrator define as propriedades padrão do conector do coletor do Migrator para cada banco de banco de dados de origem suportada . As propriedades do conector podem ser substituídas adicionando-as no arquivo user.properties com o prefixo migrator.connector.sink.common. Por exemplo:

migrator.connector.sink.common.errors.max.retries: 0

Neste exemplo, o valor padrão é cinco, mas agora foi definido como zero. Isso significa que não há novas tentativas.