Programowanie kafka-producer-api

Zrozumienie tematów i partycji platformy Kafka

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 identyfikator grupy tak, aby mógł …

185 apache-kafka kafka-consumer-api kafka-producer-api

Czy klucz jest wymagany podczas wysyłania wiadomości do platformy Kafka?

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ć delete.retention.ms? Czy muszę wysłać klucz jako część wiadomości? Czy dobrze jest tworzyć klucz jako część wiadomości?

102 apache-kafka kafka-consumer-api kafka-producer-api

Pytania otagowane jako kafka-producer-api