Estoy empezando a aprender Kafka para propósitos de soluciones empresariales. Durante mis lecturas, me vinieron a la mente algunas preguntas: Cuando un productor produce un mensaje, especificará el tema al que desea enviar el mensaje, ¿es así? ¿Le importan las particiones? Cuando se está...
Recientemente comencé a aprender Kafka y termino con estas preguntas. ¿Cuál es la diferencia entre Consumer y Stream? Para mí, si alguna herramienta / aplicación consume mensajes de Kafka es un consumidor en el mundo Kafka. ¿En qué se diferencia Stream ya que también consume o produce...
KeyedMessage<String, byte[]> keyedMessage = new KeyedMessage<String, byte[]>(request.getRequestTopicName(), SerializationUtils.serialize(message)); producer.send(keyedMessage); Actualmente, estoy enviando mensajes sin ninguna clave como parte de los mensajes con clave, ¿seguirá...
Estoy usando la versión 1.3.0 del cliente Confluent.Kafka .NET. Estoy siguiendo los documentos : var consumerConfig = new ConsumerConfig { BootstrapServers = "server1, server2", AutoOffsetReset = AutoOffsetReset.Earliest, EnableAutoCommit = true, EnableAutoOffsetStore = false, GroupId =...