Je commence à apprendre Kafka à des fins de solution d'entreprise. Au cours de mes lectures, quelques questions me sont venues à l'esprit: Lorsqu'un producteur produit un message - il spécifie le sujet auquel il souhaite envoyer le message, n'est-ce pas? Se soucie-t-il des partitions? Lorsqu'un...
KeyedMessage<String, byte[]> keyedMessage = new KeyedMessage<String, byte[]>(request.getRequestTopicName(), SerializationUtils.serialize(message)); producer.send(keyedMessage); Actuellement, j'envoie des messages sans clé dans le cadre de messages à clé, est-ce que cela fonctionnera...
J'utilise la version 1.3.0 du client Confluent.Kafka .NET. Je suis les docs : var consumerConfig = new ConsumerConfig { BootstrapServers = "server1, server2", AutoOffsetReset = AutoOffsetReset.Earliest, EnableAutoCommit = true, EnableAutoOffsetStore = false, GroupId = this.groupId, SecurityProtocol...