Kafka es un sistema de mensajería de código abierto y un corredor de cola robusto

Kafka Software de cola de mensajes gratis

Plataforma de transmisión de eventos distribuidos basados ​​en Scala y Java

Apache Kafka es una plataforma de transmisión de eventos distribuidos de código abierto. Es un corredor de cola robusto y construido como un sistema de mensajería interno desarrollado por Linked-In

Descripción general

Kafka es un sistema de mensajería de código abierto y un corredor de cola robusto. Se distribuye la plataforma de transmisión de eventos y tiene la capacidad de manejar un alto volumen de mensajes. Los mensajes de Kafka se almacenan en el disco y le permite enviar mensajes de un punto a otro sin problemas. Los mensajes se replican dentro de todo el clúster Kafka para evitar que las operaciones no deseadas ocurran como cualquier pérdida de datos. Plataforma de mensajería KAFKA construida para manejar la transmisión de eventos en tiempo real, la línea de tuberías y la reproducción de datos para operaciones rápidas y escalables. El software de cola de mensajes distribuidos de Apache Kafka es utilizado por miles de compañías para tuberías de datos de alto rendimiento y su integración con Apache Storm y Spark. Kafka ofrece un alto rendimiento en comparación con los corredores de mensajes y colas como ActivemQ y RabbitMQ, etc. Apache Kafka es una alternativa a una variedad de sistemas de mensajería empresarial. Fue construido como un sistema de mensajería interno desarrollado por Linked-In para manejar 1.4 billones de mensajes en un día. Es una plataforma mejor y adecuada para la implementación de colas, ya que aumenta el rendimiento mediante el uso de operaciones de E/S de disco secuencial. También es una opción perfecta para los casos de uso de big data porque puede lograr un alto rendimiento con un número limitado de recursos, es decir, millones de mensajes por segundo. El software de código abierto de Kafka tiene 19.4k estrellas GitHub y 10.3k GitHub Forks.

Requisitos del sistema

Requisitos para configurar el software Apache Kafka incluye:

  • Java 8+
  • Zookeeper
  • Ubuntu 20.04 LTS
  • Git

Características

Algunas de las características clave de Apache Kafka se enumeran a continuación:

  • Escalabilidad
  • Alto volumen
  • Transformaciones de datos
  • Tolerancia a fallos
  • Fiabilidad
  • Durabilidad
  • Actuación
  • Tiempo de inactividad cero
  • Extensibilidad
  • Replicación
  • Fuente abierta

Instrucciones de instalación

Instale Apache Kafka en Ubuntu

Esta guía explica cómo configurar y Kafka. A continuación, los pasos de instalación asumen que todos los paquetes de dependencia de Kafka están instalados y actualizados en su sistema. Siga a continuación los pasos de instalación. Obtenga kafka descargando el último lanzamiento Kafka y extraiga con comandos:

    tar -xzf kafka_2.13-2.8.0.tgz
    cd kafka_2.13-2.8.0

A continuación, comience el entorno Kafka. El entorno del sistema local debe tener Java 8+ instalado. Ejecute los siguientes comandos para iniciar todos los servicios en el orden correcto:

    bin/zookeeper-server-start.sh config/zookeeper.properties

Abra otra sesión de terminal y dtart el servicio de corredor de Kafka por:

    bin/kafka-server-start.sh config/server.properties

Cuando todos los servicios se hayan instalado correctamente, tendrá un entorno básico de Kafka en ejecución y listo para acceder. Debe crear un tema antes de escribir su primer evento. Abra otra sesión de terminal y ejecute el comando:

    bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092

Ahora, ejecute el cliente productor de consola para escribir algunos eventos separados en el tema:

    bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092

Abra otra sesión de terminal de consola y ejecute el cliente de consola de consola para leer los eventos con los que acaba de crear:

    bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092

Puede importar/exportar continuamente sus datos dentro y fuera de Kafka. Use CTRL-C para detener al corredor de Kafka. Si también desea eliminar los datos de su entorno Kafka local, incluidos los eventos que haya creado en el camino, ejecute el comando:

    rm -rf /tmp/kafka-logs /tmp/zookeeper

¡Felicidades! Ha configurado con éxito la plataforma Apache Kafka en Ubuntu. ¡Disfrutar!

Preguntas frecuentes

¿Para qué se usa Apache Kafka?

Kafka es un software de código abierto que proporciona un marco para almacenar, leer y analizar datos de transmisión. Ser de código abierto significa que es esencialmente gratuito de usar y tiene una gran red de usuarios y desarrolladores que contribuyen a actualizaciones, nuevas funciones y ofreciendo soporte para nuevos usuarios.

¿Apache Kafka es gratis?

Apache Kafka es gratuito, y Confluent Cloud es muy barata para pequeños casos de uso, alrededor de $ 1 al mes para producir, almacenar y consumir un GB de datos.

¿Es Apache Kafka Open Source?

Apache Kafka es una plataforma de transmisión de eventos distribuida de código abierto utilizada por miles de compañías para tuberías de datos de alto rendimiento, análisis de transmisión, integración de datos y aplicaciones críticas de misión. El código fuente de la aplicación CEPH está disponible en Github.

¿En qué idioma está escrito Kafka?

Kafka comenzó como un proyecto en LinkedIn y luego fue de origen abierto para facilitar su adopción. Está escrito en Scala y Java, y es parte de la Fundación de software Apache de código abierto.

¿Por qué Kafka es tan rápido?

Compresión y lotes de datos: Kafka incluye los datos en fragmentos, lo que ayuda a reducir las llamadas de la red y convertir la mayoría de las escrituras aleatorias a las secuenciales. Es más eficiente comprimir un lote de datos en comparación con la comprimir mensajes individuales.

Explorar

En este artículo discutimos sobre Apache Kafka. Para aprender sobre otro software de cola de mensajes (MQ), visite las siguientes páginas:

Software MQ MQ Software de la cola de mensajes de código abierto top 5

Sistema de colas redisbacked para procesamiento de fondo

httpsproductScontainerizeCommessageueuSoftWaresidekiq

 Español