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 aplicativo Relational Migrator é executado.

migrator.kafka.bootstrap.servers

Uma lista de host:port pares do seu cluster kafka 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 dados de origem suportada. As propriedades do conector podem ser substituídas adicionando-as no user.properties arquivo 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 conector do coletor

O Relational Migrator define as propriedades padrão do conector do coletor do Migrator para cada banco de dados de origem suportada. As propriedades do conector podem ser substituídas adicionando-as no user.properties arquivo 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.