Resultados de la búsqueda a petición "kafka-producer-api"
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 ...
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 ...
¿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 ...
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 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 ...
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 ...
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 ...
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.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 ...
Página 1 de 2