Resultados de la búsqueda a petición "kafka-producer-api"
Obteniendo el último mensaje enviado a un tema kafka
Soy nuevo en Kafka y estoy trabajando en un prototipo para conectar un servicio de transmisión patentado a Kafka. Estoy buscando obtener la clave del último mensaje enviado sobre un tema, ya que nuestro consumidor interno de transmisiones debe ...
Apache Kafka y Avro: org.apache.avro.generic.GenericData $ Record no se puede enviar a com.harmeetsingh13.java.Customer
Cada vez que intento leer el mensaje de la cola kafka, recibo la siguiente excepción: [error] (run-main-0) java.lang.ClassCastException: org.apache.avro.generic.GenericData$Record cannot be cast to com.harmeetsingh13.java.Customer ...
NoBrokersAvailable: NoBrokersAvailable-Kafka Error
Ya empecé a aprender Kafka. Intentando operaciones básicas en él. Me he quedado estancado en un punto sobre los 'Brokers'. Mi kafka se está ejecutando pero cuando quiero crear una partición. from kafka import TopicPartition (ERROR THERE) ...
Pedido de particiones múltiples Kafka
Soy consciente de que no es posible ordenar múltiples particiones en Kafka y que el orden de las particiones solo está garantizado para un solo consumidor dentro de un grupo (para una sola partición). Sin embargo, con Kafka Streams 0.10, ¿ahora ...
Kafka 0.10 Java Client TimeoutException: lote que contiene 1 registro (s) caducado
Tengo una configuración de Zookeeper / Kafka de un solo nodo, corredor múltiple (3). Estoy usando el cliente Java Kafka 0.10. Escribí el siguiente productor remoto simple (en un servidor diferente al de Kafka) (en el código reemplacé mi ...
Kafka 0.8.2.2 - No se pueden publicar mensajes
Hemos escrito un cliente java para publicar mensajes en kafka. El código se muestra a continuación. Properties props = new ...
¿Cómo configurar el registro para los productores de Kafka?
Estoy usando el cliente productor de Kafka y no tengo ninguna configuración log4j en mi proyecto. Al ejecutarse, el programa imprime muchos registros de Kafka Debug que realmente no quiero. Entonces, intenté agregar un log4j.properties para ...
Kafka Streams no incrementa el desplazamiento en 1 al producir el tema
He implementado un sencillo procesador de registros de letras muertas de Kafka. Funciona perfectamente cuando se utilizan registros producidos por el productor de la consola. Sin embargo, encuentro que nuestras aplicaciones de Kafka Streams no ...
Comprender los temas y particiones de Kafka
Estoy empezando a aprender Kafka para propósitos de soluciones empresariales. Durante mis lecturas, me vinieron a la mente algunas preguntas: Cuando un productor está produciendo un mensaje: especificará eltemaquiere enviar el mensaje a, ¿es ...
No se puede generar un mensaje a kafka desde el servicio que se ejecuta en la ventana acoplable
Tengo un servicio de descanso que se ejecuta en el contenedor docker en el puerto 5000 que se usa para generar mensajes sobre el tema kafka que se está quedando sin el contenedor docker. He configurado mi cliente productor con las siguientes ...
Página 1 de 2