https://dzone.com/articles/kafka-topic-architecture-replication-failover-and
Youtube:
https://www.youtube.com/watch?v=udnX21__SuU
ProduceRecord constructor contains Topic, Key and Value.
send(ProducerRecord<K,V> record):Future<RecordMetadata>; |
---|
AProducerRecord
contains a key (K) and a value (V). The value is the payload of your message (unlike in JMS there is noMessage
construct that allows you to send additional message metadata). The key is a business value provided by you that is used to shard your messages across the partitions.