Instale Apache Kafka en Ubuntu
Instalación de Apache Kafka
Primero actualice el caché del repositorio de paquetes de su servidor Ubuntu con el siguiente comando:
$ sudo apt-get actualización
El caché del repositorio del paquete debe actualizarse.
Apache Kafka depende de Java. Puede instalar OpenJDK 8 en Ubuntu 17.10 del repositorio oficial de paquetes.
Ejecute el siguiente comando para instalar OpenJDK 8 en Ubuntu 17.10:
$ sudo apt-get install OpenJDK-8-JDK
Ahora presione 'Y' y luego presione para continuar.
OpenJDK 8 debe instalarse.
Ahora tienes que instalar choque. Está disponible en el repositorio oficial de paquetes de Ubuntu.
Instalar choque, Ejecute el siguiente comando:
$ sudo apt-get install Zookeeperd
Ahora presione 'Y' y luego presione para continuar.
choque debe instalarse.
Puede ejecutar el siguiente comando para verificar si choque Esta corriendo:
$ sudo systemctl status zookeeper
Como puede ver en la captura de pantalla a continuación, choque Esta corriendo.
Si no se está ejecutando en su máquina por alguna razón, puede comenzar choque Con el siguiente comando:
$ sudo systemctl iniciar zookeeper
Deberías agregar choque al inicio del sistema. Entonces comenzará automáticamente al arranque.
Ejecute el siguiente comando para agregar choque al inicio del sistema:
$ sudo systemctl habilitar ZOOKEEPER
choque debe agregarse al inicio del sistema como puede ver en la captura de pantalla a continuación.
Necesito netstat comando que proporciona el toallas de red paquete.
Ahora instalar toallas de red Paquete con el siguiente comando:
$ sudo apt-get instalación de redes
toallas de red Se debe instalar el paquete.
Ahora puede ejecutar el siguiente comando para verificar si Zookeeper se está ejecutando en el puerto 2181.
$ sudo netstat -tulpen | GREP 2181
Como puede ver, se ejecuta en el puerto 2181.
Ahora ejecute el siguiente comando para navegar al directorio ~/ descargas/ en el directorio de inicio de sus usuarios:
$ cd ~/descargas
Ahora tienes que descargar Apache Kafka. Al momento de escribir, la última versión de Apache Kafka es V1.0.0.
Ejecute el siguiente comando para descargar Apache Kafka 1.0.0 con wget:
$ wget http: // www-eu.apache.org/dist/kafka/1.0.0/kafka_2.12-1.0.0.tgz
El archivo comprimido de apache kafka se debe descargar.
Como puede ver en la salida del comando ls, el nombre de archivo del archivo apache kafka es kafka_2.12-1.0.0.tgz
Ahora crea un directorio Kafka/ en el /optar directorio con el siguiente comando:
$ sudo mkdir /opt /kafka
Un directorio /opt/kafka debe crearse. Aquí es donde extraeré el archivo.
Ahora extrae el archivo Apache Kafka en el /opt/kafka directorio con el siguiente comando:
$ sudo tar xvzf kafka_2.12-1.0.0.TGZ -C /Opt /Kafka
El archivo debe extraerse.
Puede ejecutar el siguiente comando para verificar el nombre del directorio:
$ ls /opt /kafka
Tenga en cuenta que el nombre del directorio.
Ahora abierto /etc/perfil Con el siguiente comando:
$ sudo nano /etc /perfil
Agregue las siguientes líneas al final del archivo y guárdelo.
Ahora abre el ~/.bashrc Archivo con el siguiente comando:
$ sudo nano ~/.bashrc
Agregue la línea marcada al final del archivo como guardarlo.
Ahora reinicie su computadora con el siguiente comando:
$ sudo reinicio
Una vez que se inicia su computadora, puede verificar si las variables de entorno se agregan de la siguiente manera:
$ echo $ kafka_home
$ echo $ ruta
Ahora para facilitar nuestra vida, hacer un enlace simbólico de Kafka servidor.propiedades Archivo de la siguiente manera:
$ sudo ln -s $ kafka_home/config/servidor.propiedades /etc /kafka.propiedades
Como puede ver en la captura de pantalla a continuación, se crea el enlace simbólico.
Ahora puede iniciar el servidor Apache Kafka con el siguiente comando:
$ sudo kafka-server-start.sh /etc /kafka.propiedades
El servidor Apache Kafka debe iniciarse.
Prueba del servidor Apache Kafka
Puedes crear un tema de prueba pruebas En el servidor Apache Kafka con el siguiente comando:
$ sudo kafka-topics.SH-CREATE-ZOOKEEPER LOCALHOST: 2181-Factor de replicación 1
--Partitions 1 -topic tope
A pruebas El tema debe crearse como se muestra en la captura de pantalla a continuación.
Ahora ejecute el siguiente comando para usar la API del productor de Kafka para enviar algún mensaje al pruebas tema:
$ sudo kafka-comoductor.SH-Broker-List Localhost: 9092-Prueba de tope
Una vez que presione, debería ver un nuevo signo de flecha (>) como se muestra en la captura de pantalla a continuación.
Simplemente escriba algo y presione para comenzar una nueva línea. Escribí 3 líneas de textos.
Ahora puede usar la API de consumidor de Kafka para obtener los mensajes/líneas del pruebas tema con el siguiente comando:
$ sudo kafka-consolse-consolutor.SH --zookeeper localhost: 2181 --
Prueba de temas: desde el beginismo
Debería poder ver los mensajes o líneas que ha escrito utilizando la API del productor como marcada en la captura de pantalla a continuación.
Si escribe un nuevo mensaje utilizando la API del productor, también se debe mostrar instantáneamente en el lado del consumidor como se muestra en la captura de pantalla a continuación.
Así es como instala Apache Kafka y verifica que funcione en Ubuntu 17.10 Artful Aardvark. Gracias por leer este artículo.