Ich fange an, Kafka für Unternehmenslösungszwecke zu lernen. Während meiner Lesungen kamen mir einige Fragen in den Sinn: Wenn ein Produzent eine Nachricht produziert, gibt er das Thema an, an das er die Nachricht senden möchte. Ist das richtig? Interessiert es sich für Partitionen? Wenn ein...
Ich habe vor kurzem angefangen, Kafka zu lernen und am Ende diese Fragen. Was ist der Unterschied zwischen Consumer und Stream? Wenn ein Tool / eine Anwendung Nachrichten von Kafka konsumiert, ist dies für mich ein Verbraucher in der Kafka-Welt. Wie unterscheidet sich Stream, da dies auch...
KeyedMessage<String, byte[]> keyedMessage = new KeyedMessage<String, byte[]>(request.getRequestTopicName(), SerializationUtils.serialize(message)); producer.send(keyedMessage); Derzeit sende ich Nachrichten ohne Schlüssel als Teil von Schlüsselnachrichten. Funktioniert dies weiterhin...
Ich bin nicht klar , warum wir beide brauchen session.timeout.msund max.poll.interval.msund wann würden wir verwenden eine oder das andere oder beides? Anscheinend geben beide Einstellungen die Obergrenze für die Zeit an, die der Koordinator wartet, um den Herzschlag eines Verbrauchers zu...
Ich muss einen Weg finden, Kafka nach einer Liste von Themen zu fragen. Ich weiß, dass ich das mit dem kafka-topics.shim bin\Verzeichnis enthaltenen Skript tun kann . Sobald ich diese Liste habe, brauche ich alle Verbraucher pro Thema. Ich konnte weder ein Skript in diesem Verzeichnis noch eine...
Ich verwende Confluent.Kafka .NET Client Version 1.3.0. Ich folge den Dokumenten : var consumerConfig = new ConsumerConfig { BootstrapServers = "server1, server2", AutoOffsetReset = AutoOffsetReset.Earliest, EnableAutoCommit = true, EnableAutoOffsetStore = false, GroupId = this.groupId,...