Resultados de la búsqueda a petición "apache-kafka"
Cómo configurar temas de Kafka para que las bases de datos como RDMS y gráficas puedan consumir un esquema de entidad interconectada en forma de eventos
Tengo un caso donde tengoInformation objetos que contienenElement objetos. Si guardo unInformation objetará que intentará encontrar preexistenteElement objetos basados en un campo de valor único; de lo contrario, insértelos.Information objetos ...
Código de error del consumidor de alto nivel de Kafka = 15
Cuando se trata de consumir desde Kafka usando el consumidor de alto nivel (usando un grupo de consumidores completamente nuevo), el consumidor nunca comienza a funcionar. Cuando cambio el nivel de registro a depuración, puedo ver las dos líneas ...
Kafka Zookeeper seguridad
Estoy usando Kafka Versión 0.10.2.0. ¿Hay alguna forma de asegurar la comunicación entre Zookeper Client, es decir, ZkClient y el servidor zookeper con SSL? Encontré alguna forma de hacerlo a través de SASL pero lo quiero a través de SSL.
Filtrado de flujos de Kafka: ¿corredor o consumidor?
Estoy mirando las corrientes de kafka. Quiero filtrar mi flujo, usando un filtro con muy baja selectividad (uno en unos pocos miles). Estaba mirando este ...
Excepción en el hilo "principal" java.lang.NoClassDefFoundError: org / spark_project / guava / cache / CacheLoader
Cuando estoy tratando de ejecutar mi proyecto kafka spark. Me aparece el siguiente error: Exception in thread "main" java.lang.NoClassDefFoundError: org/spark_project/guava/cache/CacheLoader ...
Kafka rack-id y min réplicas sincronizadas
Kafka ha introducido id de rack para proporcionar capacidades de redundancia si falla un rack completo. Hay una configuración mínima de réplica sincronizada para especificar la cantidad mínima de réplicas que deben sincronizarse antes de que un ...
Spark Structured Streaming - Procesando cada fila
Estoy usando transmisión estructurada con Spark 2.1.1. Necesito aplicar algo de lógica empresarial a los mensajes entrantes (de la fuente Kafka). esencialmente, necesito recoger el mensaje, obtener algunos valores clave, buscarlos en HBase y ...
Transmisión de mensajes a múltiples temas
Tengo un solo tema maestro y múltiples predicados, cada uno de los cuales tiene un tema de salida asociado. Quiero enviar cada registro a TODOS los temas cuyo predicado se resuelva en verdadero. Estoy usando Luwak para probar qué predicados ...
Kafka 0.11.0.0 sigue restableciendo el desplazamiento al reiniciar
Tengo un problema con Kafka 0.11.0.0 Cuando creo un nuevo tema, ingrese los datos y lo consuma con un consumidor de Java, después de reiniciar Kafka 0.11.0.0, las compensaciones para mi grupo de consumidores desaparecen. El tema permanece y ...
Cómo ver el mensaje kafka
¿Hay alguna manera de ver el contenido del mensaje enviado a kafka para un tema determinado? Diga algo como ver los últimos 5 mensajes para este tema, si es posible. gracias Sandeep