Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
En Kafka Stream, las tareas de stream se distribuirán entre las instancias en un entorno de múltiples instancias (y, por lo tanto, las particiones se distribuirán). Por otro lado, una de las diferencias entre KTable y GlobalKTable es que KTable distribuye las particiones entre las instancias (desde Mastering Kafka Streams . . . Read more
Tengo una aplicación de procesamiento de flujo que utiliza el formato de mensaje AVRO. Para la serialización y deserialización (Serde) se utiliza io.confluent.kafka.streams.serdes.avro.GenericAvroSerde. Intenté crear un Serde AVRO personalizado como el siguiente: public class CustomAvroSerde implements Serde { Class<SpecificRecord> targetType; public CustomAvroSerde() { } public CustomAvroSerde(Class<SpecificRecord> targetType) { this.targetType = . . . Read more