Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Antes de comenzar, es importante mencionar que soy nuevo en Kafka Streams y no soy programador de Java. Todo lo que sé es por leer muchos artículos en los últimos días y revisar algunos ejemplos de Tutorial de Kafka. Tengo un requisito de combinar eventos que ocurren en momentos bastante . . . Read more
Tengo una aplicación de Kafka Streams versión 2.5.1 (kafka spring) y conectores CDC que continuamente producen datos en el tema. Tengo un total de 14 temas que se unen a los datos como se muestra a continuación y producen el resultado en el tema final. ktable1.join(ktable2).leftJoin(ktable3).leftJoin(ktable4).to(finalTopic) Cuando aumenta la carga . . . Read more
Desarrollamos un marco interno de la empresa sobre Spring Boot y nos gustaría compatibilizar Kafka-Streams con Spring Cloud Stream. Necesitamos inyectar automáticamente algunos encabezados en todos los mensajes salientes. Hemos logrado esto con el Binder Kafka de Spring Cloud Stream al registrar un ChannelInterceptor personalizado, pero esto no funciona para . . . Read more
Soy nuevo en Kafka. Estoy usando Spring Cloud Stream Kafka en mi proyecto, también estoy escribiendo código de manera funcional. Quiero consumir un mensaje de un único tema de entrada, construir diferentes modelos a partir del mensaje y publicar cada modelo en un tema diferente (es decir, 1 modelo -> . . . Read more
@StreamListener(“notification-input-channel”) @SendTo(“notification-output-channel”) public KStream<string,notification> process(KStream<string,posinvoice> input) { KStream<string,notification> notificationStream=input. filter((k,v)->v.getCustomerType.equals(“Prime”)). mapValues(v->recordBuilder.getNotification(v)); return notificationStream; } En primer lugar, soy completamente nuevo en Kafka. Ahora, respecto a mi pregunta: en el KStream de entrada, estoy obteniendo el valor como String y Kafka luego lo convierte en un objeto PosInvoice. Pero en el . . . Read more