Instalar com um cluster Kafka existente
Nesta página
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.
Antes de começar
Você deve ter Kafka e conectividade de rede com o cluster do Kafka Connect a partir do computador que executa o Relational Migrator.
Passos
Instalar o plug-in de conexão da fonte Debezium
Baixe o arquivo do conector de origem para seu banco de dados de dados de origem :
Descompacte o arquivo.
Copie o arquivo
debezium-connector.jar
para o diretóriodebezium-connector
.A partir do arquivo baixado, copie o
debezium-connector.jar
arquivo para odebezium-connector-xxx
diretório no plugin.path do Kafka Connect no seu cluster do Kafka Connect. Por exemplo:/kafka/connect/debezium-connector-sqlserver
.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'
Instalar o plugin -in Relational Migrator Sink Connect
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.Copie o arquivo
.jar
para o diretóriokafka-connect-migrator
.O novo
kafka-connect-migrator
diretório é encontrado em plugin.path do Kafka Connect . Por exemplo:/kafka/connect/kafka-connect-migrator
.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'
Instalar o Relational Migrator
No centro de download, selecione a versão mais recente do instalador do Relational Migrator.
Execute o Relational Migrator no modo integrado ao Kafka
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:
Defina o valor do perfil como |
server.port | 8278 | A porta em que o aplicativo Relation Migrator é executado. |
migrator.kafka.bootstrap.servers | Nenhum padrão | Esta é uma lista de 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: |
Confirme a instalação bem-sucedida
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 .