Menu Docs
Página inicial do Docs
/
Relational Migrator
/ /

Instalar com um cluster Kafka existente

Nesta página

  • Antes de começar
  • Passos
  • Próximos passos
  • Saiba mais

Você pode instalar o Relational Migrator em um cluster Kafka existente, incluindo o Kafka Connect. Esse método de instalação é ideal se você já estiver executando o Kafka ou se tiver sua própria abordagem para instalar e configurar o Kafka.

Você deve ter Kafka e conectividade de rede com o cluster do Kafka Connect a partir do computador que executa o Relational Migrator.

1
  1. Baixe o arquivo do conector de origem para seu banco de dados de origem:

  2. Descompacte o arquivo.

  3. Copie o arquivo debezium-connector.jar para o diretório debezium-connector .

    A partir do arquivo baixado, copie o debezium-connector.jar arquivo para o debezium-connector-xxx diretório no plugin.path do Kafka Connect no seu cluster do Kafka Connect. Por exemplo: /kafka/connect/debezium-connector-sqlserver.

  4. Reinicie seu cluster do Kafka Connect.

    Quando o plugin é registrado com sucesso, a seguinte declaração de registro aparece nos registros de inicialização do kafka-connect :

    INFO || Added plugin 'io.debezium.connector.sqlserver.SqlServerConnector'
2
  1. Baixe a versão mais recente do arquivo kafka-connect-migrator.jar .

    Para baixar o kafka-connect-migrator.jar arquivo mais recente, consulte o Repositório do Instalador do Migrator.

  2. Copie o arquivo .jar para o diretório kafka-connect-migrator .

    O novo kafka-connect-migrator diretório é encontrado em plugin.path do Kafka Connect . Por exemplo: /kafka/connect/kafka-connect-migrator.

  3. Reinicie seu cluster do Kafka Connect.

    Quando o plugin é registrado com sucesso, a seguinte declaração de registro aparece nos registros de inicialização do kafka-connect :

    INFO || Added plugin 'com.mongodb.migrator.kafka.connect.MigratorSinkConnector'
3

No centro de download, selecione a versão mais recente do instalador do Relational Migrator.

4

Para executar no modo kafka-integrated , atualize as seguintes configurações em seu arquivo user.properties .

Seu arquivo user.properties está localizado em um local específico do sistema operacional. Para obter mais informações, consulte Locais de arquivo do Relational Migrator.

Nome da propriedade
default
Descrição
spring.profiles.active
Local

O Relational Migrator pode ser executado no seguinte perfil:

  • kafka: Servidor remoto usando sistema de servidor incorporado.

  • confluent: Servidor remoto usando o Confluent Cloud para Kafka gerenciado

Defina o valor do perfil como kafka.

server.port
8278
A porta em que o aplicativo Relation Migrator é executado.
migrator.kafka.bootstrap.servers
Nenhum padrão

Esta é uma lista de host:port pares do seu cluster kafka preexistente.

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

migrator.kafka.connect.url
Nenhum padrão
O URL do host do Kafka Connect usando o formato {host}:{port} .
migrator.kafka.connect.metrics.jmx.service.url
Nenhum padrão

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

Por exemplo: service:jmx:rmi:///jndi/rmi://localhost:9876/jmxrmi

5

Inicie o Relational Migrator e verifique os logs. Confirme que o perfil Kafka está ativo e que não há erros.

Seu arquivo log está localizado em um local específico do sistema operacional. Para obter mais informações, consulte Locais de arquivos do Relational Migrator.

Voltar

Integração com Kafka