Conéctese de forma remota al servidor Kafka y cree un servicio de implementación de temas en Windows

Luego cambie al directorio del proyecto para encontrar build.sh, luego ejecútelo para empaquetar la imagen del proyecto

Este es el primero tiempo en el paquete Dockerfile la imagen del proyecto. Busque build.sh en el directorio del proyecto y ejecútelo para empaquetar la imagen del proyecto

si

error: "Falló el acceso telefónico a gRPC: no se puede conectar al demonio Docker. Se está ejecutando en este host ¿Se está ejecutando 'docker daemon' en este host?: marque unix /var/run/docker.sock: conectar: ​​permiso denegado

"

Simplemente use

lo siguiente para indicar que el paquete se ha instalado correctamente y que puede comenzar la implementación:

/article/ 9113f81b49ed2f2b3214c7fa.html

NOTA: Si el permiso de solo lectura no se puede modificado, puede copiar el archivo host al escritorio y reemplazar el archivo host original después de la modificación

Agregue el servidor Kafka al final del archivo hosts

1.1 Nota: Modifique el archivo de hosts del servidor Alibaba Cloud y configure la dirección del servidor Kafka:

Agregue al final del archivo de hosts:

Agregar El servidor kafka es el servidor kafka utilizado en el comando de creación de tema a continuación.

Alias,

Escuchando Kafka remoto: nuevo consumidor:

Instancia de tema creado remotamente:

Visualización de tema creado remoto:

Local :

Tema de Kafka modificado remotamente:

2. Cambie al directorio Bin del cliente Kafka:

Abra gitBash en el escritorio y cambie al Kafka local. directorio de software:

Aquí, asegúrese de cambiar a Windows

3. Ver temas existentes

--el tema especifica el nombre del tema

- -replication-factor especifica la cantidad de réplicas. Debido a que el mío es un entorno de clúster, la cantidad de réplicas aquí es 3

--partitions especifica la cantidad de particiones. Este parámetro debe determinarse en función. la cantidad de agentes y la cantidad de datos En términos generales, es mejor tener dos particiones en cada proxy.

Nota: El servidor debe usarse para implementar la red interna 172.. y la IP externa para. acceso externo

De lo contrario, Kafka escribirá Se produjo un error durante el procesamiento de datos: Timeout

4.1 Crear un tema usando la ventana acoplable local:

4.2 Crear un tema usando local windows

Ingrese la ruta del software local KAFKA/BIN/ WIONDOWS

Cree un tema

5. Modifique el host del servidor:

Asegúrese de agregar sudo, de lo contrario será de solo lectura y no se podrá modificar

Al final del archivo host Agregue el siguiente contenido:

6. Cambie al directorio donde está implementado el proyecto

7. Limpiar redis; de lo contrario, quedarán datos:

7.1 Limpiar redis en el servidor Montar:

Comentar estas líneas en docker-compose.yml: el propósito no es registrar los datos que no se ejecutaron la última vez cada vez que se inicia.

Esto se utilizará para registrar el número de bloques de datos no ejecutados en redis si el último bloque de datos especificado estaba entre 1 y 1 millón. La próxima vez que se ejecute la tarea inacabada, la prueba se cerrará temporalmente

7.2 Eliminar el volumen:

7.3 Si el archivo del volumen está ocupado, elimine primero el contenedor ocupado:

7.4 Borrar datos en redis

Ingresar al contenedor de redis:

8. Comando de implementación:

8.1 Habilitar la visualización de Docker en la red para monitorear ventana acoplable:

Luego acceda: La línea 46 en el archivo pose.yml informó un error

Solución: Alinee todos los datos sin espacios adicionales.

Solución: Alinear todos los datos y eliminar los espacios sobrantes.