Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Tengo varios temas de entrada de diferentes sistemas con el mismo tipo de evento, por ejemplo: tema1: { id: 1, timestamp: t1, content: “…” } { id: 2, timestamp: t3, content: “…” } { id: 3, timestamp: t5, content: “…” } tema2: { id: 4, timestamp: t2, content: “…” } . . . Read more
Coloqué un objeto JSON en mi tema “commits”. Quiero consumir mensajes usando Kafka Streams, pero hay un error. @Configuration @EnableKafka @EnableKafkaStreams public class AnalyzerConfiguration { @Bean(name = KafkaStreamsDefaultConfiguration.DEFAULT_STREAMS_CONFIG_BEAN_NAME) public KafkaStreamsConfiguration kStreamsConfigs() { Map<string, object=””> props = new HashMap<>(); props.put(StreamsConfig.APPLICATION_ID_CONFIG, “test-streams”); props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, “localhost:9092”); props.put(StreamsConfig.DEFAULT_KEY_SERDE_CLASS_CONFIG, Serdes.String().getClass().getName()); props.put(StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG, commitSerde().getClass()); return new KafkaStreamsConfiguration(props); } . . . Read more
Escribí el siguiente código para suscribirme a Kafka: subscribeTable(tableName=”tab_share17″, actionName=”device”, handler=power14, msgAsTable=true, batchSize=1, throttle=10) El sistema tarda bastante tiempo en leer los datos. ¿Qué se puede hacer para reducir la latencia?
Estoy aprendiendo sobre Kafka y me intriga cómo debería existir un cliente de Kafka en una arquitectura de microservicios. Quiero que Kafka registre información importante y facilite una reacción automática a esa información de manera apropiada. Mi pregunta es ¿cómo debería existir Kafka con el backend como un microservicio? Cliente . . . Read more
Siendo bastante familiarizado con Apache Camel, soy nuevo en Kafka Streams. Estoy aprendiendo Kafka Streams, pero no pude encontrar ninguna respuesta relevante para la siguiente consulta, Siendo una biblioteca, tanto Camel como Kafka Streams pueden crear canales para extraer datos, pulir/transformar y cargar en algún destino utilizando un procesador. Camel . . . Read more