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 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 Kafka cluster 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