¿Dónde puedo encontrar el repositorio de maven para kafka?

Kafka Storm HDFS / S3 flujo de datos

No está claro si puedes hacer un fan-out (duplicación) en Kafka como puedes hacerlo en Flume.Me gustaría que Kafka guarde los datos en HDFS o S3 y envíe un d...

Usando Kafka como un almacén de eventos (CQRS). ¿Buena idea?

¿Hay una manera de eliminar todos los datos de un tema o eliminar el tema antes de cada ejecución?

Kafka: no se pueden crear múltiples consumidores de flujo

Me puse en marcha con Kafka 0.8 beta 1. Tengo un ejemplo muy simple en funcionamiento, el problema es que solo puedo hacer que un consumidor de mensajes func...

Cómo integrar Storm y Kafka [cerrado]

Codec de mensaje Kafka - comprimir y descomprimir

Cuando usaskafka, Puedo configurar un códec configurando la propiedad kafka.compression.codec de mi productor kafka.Supongamos que uso la compresión snappy e...

Consumo de mensajes de Apache Kafka cuando las particiones superan a los consumidores

¿Cuántos productores crear en kafka?

En una aplicación web java en tiempo real de gran volumen, le envío mensajes aapache kafka. Actualmente estoy enviando a un solo tema, pero en el futuro podr...

Consumidor de alto nivel de Kafka Obtenga todos los mensajes del tema utilizando la API de Java (equivalente a --desde el principio)

Estoy probando el consumidor de alto nivel de Kafka usando el código ConsumerGroupExample del sitio de Kafka. Me gustaría recuperar todos los mensajes existentes sobre el tema llamado "prueba" que tengo en la configuración del servidor Kafka. Al ...