Resultados de la búsqueda a petición "kafka-producer-api"

1 la respuesta

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 ...

1 la respuesta

Kafka 0.9.0.1 Java Consumer atascado en awaitMetadataUpdate ()

Estoy tratando de hacer que un Kafka Consumer simple funcione con la API de Java v0.9.0.1. El servidor kafka que estoy usando es un contenedor acoplable, que también ejecuta la versión 0.9.0.1. A continuación se muestra el código ...

1 la respuesta

Kafka: modifique el número de particiones para un tema específico utilizando Java

Soy nuevo en Kafka y estoy trabajando con KafkaProducer y KafkaConsumer, versión: 0.9.0.1. ¿Hay alguna forma en Java de alterar / actualizar el número de particiones para un tema específico después de que se haya creado? No estoy usando ...

2 la respuesta

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 ...

1 la respuesta

Política óptima de retención y eliminación de Kafka

Soy bastante nuevo en kafka, así que perdóname si esta pregunta es trivial. Tengo una configuración muy simple para propósitos de pruebas de tiempo como sigue: Máquina A -> escribe en el tema 1 (Intermediario) -> Máquina B lee del tema 1 Máquina ...

4 la respuesta

¿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 ...

1 la respuesta

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 ...

3 la respuesta

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) ...

2 la respuesta

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 ...

1 la respuesta

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 ...