El archivo SYSTEMD en Ubuntu no se está comportando como se esperaba -- linux campo con ubuntu campo con apache-kafka camp Relacionados El problema

Systemd file in ubuntu is not behaving as expected


0
vote

problema

Español

Estoy configurando un clúster de Kafka en una sola máquina para que hice 5 copias de Kafka y la configuración aplicada en consecuencia. Ahora, quiero iniciar y detener a cada zoológico individualmente usando el archivo SYSTEMD para que hice copias de los archivos SYSTEMD y los configuró de la siguiente manera. Ahora, el problema que estoy enfrentando es cuando estoy tratando de detener una instancia de ZOOKEEPER, detenga todos los zoológicos. ¿Por qué se comporta así y cómo necesito configurar el archivo SYSTEMSD?

First ZookeEPER SYSTEMMD Archivo:

  [Unit] Description=Apache Zookeeper server Documentation=http://zookeeper.apache.org Requires=network.target remote-fs.target After=network.target remote-fs.target  [Service] Type=simple ExecStart=/usr/local/kafka/bin/zookeeper-server-start.sh /usr/local/kafka/config/zookeeper.properties ExecStop=/usr/local/kafka/bin/zookeeper-server-stop.sh Restart=on-abnormal  [Install] WantedBy=multi-user.target[Unit]   

segundo archivo SystemMD:

  [Unit] Description=Apache Zookeeper server1 Documentation=http://zookeeper.apache.org Requires=network.target remote-fs.target After=network.target remote-fs.target  [Service] Type=simple ExecStart=/usr/local/kafka_1/bin/zookeeper-server-start.sh /usr/local/kafka_1/config/zookeeper.properties ExecStop=/usr/local/kafka_1/bin/zookeeper-server-stop.sh Restart=on-abnormal  [Install] WantedBy=multi-user.target[Unit]   

Los archivos Systemd restantes también son similares con la única diferencia de ruta.

Original en ingles

I am setting up a kafka cluster on a single machine for that I made 5 copies of kafka and applied configuration accordingly. Now, I want to start and stop each zookeeper individually by using systemd file for that I made copies of systemd files and configured them as below. Now the problem I am facing is when I am trying to stop one instance of zookeeper it is stopping all zookeepers. Why is it behaving like that and how i need to configure systemd file?

First zookeeper systemmd file:

[Unit] Description=Apache Zookeeper server Documentation=http://zookeeper.apache.org Requires=network.target remote-fs.target After=network.target remote-fs.target  [Service] Type=simple ExecStart=/usr/local/kafka/bin/zookeeper-server-start.sh /usr/local/kafka/config/zookeeper.properties ExecStop=/usr/local/kafka/bin/zookeeper-server-stop.sh Restart=on-abnormal  [Install] WantedBy=multi-user.target[Unit] 

Second zookeeper systemmd file:

[Unit] Description=Apache Zookeeper server1 Documentation=http://zookeeper.apache.org Requires=network.target remote-fs.target After=network.target remote-fs.target  [Service] Type=simple ExecStart=/usr/local/kafka_1/bin/zookeeper-server-start.sh /usr/local/kafka_1/config/zookeeper.properties ExecStop=/usr/local/kafka_1/bin/zookeeper-server-stop.sh Restart=on-abnormal  [Install] WantedBy=multi-user.target[Unit] 

Remaining systemd files are also similar with only path difference.

        
   
   

Lista de respuestas

0
 
vote

No necesita copias de todas las carpetas de instalación. Tampoco debe ejecutarse más de uno de Kafka o Zookeeper en la misma máquina, ya que aún tiene un un solo punto de falla , si es un disco o una interfaz de red

especialmente, ya que no está claro si ha modificado alguno de los directorios de almacenamiento predeterminados

Nota: Si instala la plataforma confluente usando Apt, viene con sus propios scripts Systemd

 

You don't need copies of the whole installation folders. You also shouldn't run more than one of Kafka or Zookeeper on the same machine since you still have a single point of failure, whether that's a disk or network interface

Especially, since it's unclear if you've modified any of the default storage directories

Note: if you install Confluent Platform using APT, it comes with its own SystemD scripts

 
 

Relacionados problema

0  ¿Cómo obtener un mapa [cadena, cadena] devuelta por un consumidor de Kafka (Alpakka)?  ( How to get a map string string returned by a kafka consumer alpakka ) 
Debería obtener una mapa [cadena, cadena] de regreso de un consumidor de Kafka, pero realmente no sé cómo. Me las arreglé para configurar al consumidor, fun...

0  ¿Kafka Broker siempre revisa si es el líder mientras responde a la solicitud de lectura / escritura  ( Does kafka broker always check if its the leader while responding to read write ) 
Estoy viendo org.apache.kafka.common.errors.notlederforpartitionException en mi productor que entiendo sucede cuando el productor intenta producir mensajes a ...

4  Kafka Consumer se recupera después del procesamiento fallido de mensajes  ( Kafka consumer recover after failed message processing ) 
Estoy trabajando con el simple consumidor de Kafka en uno de mis proyectos y mi lógica deseada es cuando el consumidor no pudo procesar algún mensaje, se comp...

10  Clase de Kafkautils no encontrada en Spark Streaming  ( Kafkautils class not found in spark streaming ) 
Acabo de empezar con Spark Streaming y estoy tratando de construir una aplicación de muestra que cuenta las palabras de una corriente de Kafka. Aunque se comp...

0  Kafka - Leer un paquete de mensajes  ( Kafka read a pack of messages ) 
Tengo un trabajo por lotes, lo que llena los datos al tema de Kafka. Cada mensaje tiene datos y identificadores de trabajo. En el lado del consumidor, quiero ...

0  Autenticación Kafka con SASL - ¿Usuario administrador duplicado?  ( Kafka authentication with sasl duplicate admin user ) 
Estoy ejecutando un agente de Kafka distribuidado donde se establece la comunicación entre broker y SASL / SSL. Para esto, me adapté a la configuración de JAA...

0  es posible activar el flujo de trabajo de Oozie justo y solo con un mensaje (es decir, con Kafka)  ( Is it possible to trigger oozie workflow just and only with a message ie with ) 
Me gustaría pasar por pase Tiempo de inicio y Frecuencia Parámetro para obtener el flujo de trabajo iniciado inmediatamente cuando se recibe el mensaje de...

0  Voltdb no busca datos de Tema de Kafka  ( Voltdb not fetching data from kafka topic ) 
Estoy usando Voltdb. Y mi caso de uso es importar datos de Kafka a Voltdb. Estoy usando el siguiente comando: Mando: Prueba de kafkaloader --brokers & lt; & ...

1  Conector de origen Kafka JDBC: cree temas de los valores de la columna  ( Kafka jdbc source connector create topics from column values ) 
Tengo un microservicio que utiliza Oracledb para publicar los cambios del sistema en la tabla EVENT_STORE . La tabla EVENT_STORE contiene una columna TYPE...

-2  La herramienta de línea de comando de consumo de Kafka no funciona como se esperaba  ( Kafka consumer command line tool not working as expected ) 
Estoy usando la herramienta de línea de comandos de Kafka para consumir datos de un tema de Kafka, pero esto no funciona como se esperaba. Estoy usando el sig...




© 2022 respuesta.top Reservados todos los derechos. Centro de preguntas y respuestas reservados todos los derechos