Zaczynam uczyć się języka Kafka dla potrzeb rozwiązań dla przedsiębiorstw. Podczas moich lektur przyszło mi do głowy kilka pytań: Kiedy producent tworzy wiadomość - określa temat, do którego chce wysłać wiadomość, czy to prawda? Czy dba o partycje? Kiedy abonent działa - czy określa swój...
Niedawno zacząłem uczyć się języka Kafka i otrzymałem te pytania. Jaka jest różnica między Consumer i Stream? Dla mnie, jeśli jakiekolwiek narzędzie / aplikacja konsumuje wiadomości od Kafki, jest konsumentem w świecie Kafki. Czym różni się usługa Stream, skoro również pobiera wiadomości z...
KeyedMessage<String, byte[]> keyedMessage = new KeyedMessage<String, byte[]>(request.getRequestTopicName(), SerializationUtils.serialize(message)); producer.send(keyedMessage); Obecnie wysyłam wiadomości bez klucza jako część wiadomości z kluczem, czy nadal będzie to działać...
Używam klienta Confluent.Kafka .NET w wersji 1.3.0. Postępuję zgodnie z dokumentami : var consumerConfig = new ConsumerConfig { BootstrapServers = "server1, server2", AutoOffsetReset = AutoOffsetReset.Earliest, EnableAutoCommit = true, EnableAutoOffsetStore = false, GroupId = this.groupId,...