Resultados de la búsqueda a petición "consumer"
No se puede encontrar el tema al generar mensajes: UNKNOWN_TOPIC_OR_PARTITION
Tengo un clúster kafka de dos nodos (instancias EC2) donde cada nodo se usa como un agente independiente. Cuando ejecuto un productor en la instancia líder con el siguiente comando: kafka-console-producer.sh --broker-list localhost:9092 --topic ...
concurrencia java: multi-productor un consumidor
Tengo una situación en la que diferentes subprocesos llenan una cola (productores) y un elemento de recuperación del consumidor de esta cola. Mi problema es ...
múltiples consumidores por fragmento de kinesis
Leí que puedes tener múltiples aplicaciones de consumo por transmisión ...
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 ...
Campo de obtención opcional
Tengo una estructura de clase como esta: public class Foo { private FooB foob; public Optional<FooB> getFoob() { return Optional.ofNullable(foob); } } public class FooB { private int valA; public int getValA() { return valA; } }Mi objetivo es ...
Biblioteca para OAuth Provider (Java) [cerrada]
Estoy buscando una biblioteca de Java que me ayude a crear un proveedor de OAuth. Debo poder recibir solicitudes firmadas por OAuth y determinar si son válid...