Kafka Producer ProducerRecord Sınıfı

Giriş

Şu satırı dahil ederiz

import org.apache.kafka.clients.producer.ProducerRecord;

constructor - topic + value

Açıklaması şöyle

Create a ProducerRecord which contains Topic and Value(data to be sent). Key(which can help us to route to specific partitions) and Partition are optional.

Örnek - schema + data gönderme

Şöyle yaparız. Burada paylaodWithSchema hem string hem de veriyi yani payload içerir.

ObjectMapper objectMapper = new ObjectMapper();
String paylaodWithSchema = "...";
JsonNode  jsonNode = objectMapper.readTree(paylaodWithSchema);
ProducerRecord<String, JsonNode> record = new ProducerRecord<>(TOPIC_NAME,jsonNode);

constructor - topic + key + value

Şöyle yaparız

String topic = "test-topic";
String key = "test-key";
String value = "test-value";

ProducerRecord<String, String> record = new ProducerRecord<>(topic, key, value);