Record(Message) 구조: Header, Key, Value

Key와 Value는 Avro, Json 등 다양한 형태가 가능

 

Serializer/Deserializer

Kafka는 Record(데이터)를 Byte Array로 저장

Key와 Value용 Serializer를 각각 설정

 

Producing to Kafka: High-Level Architecture

 

Partitioner의 역할: 메시지를 Topic의 어떤 Partition으로 보낼지 결정

Key가 null일 때, DefaultPartitioner

'~2022 > Apache Kafka' 카테고리의 다른 글

[Kafka] Replication  (0) 2022.04.07
[Kafka] Consumer  (0) 2022.04.07
[Kafka] Broker, Zookeeper  (0) 2022.04.07
[Kafka] Topic, Partition, Segment  (0) 2022.04.06
[Kafka] server.properties  (0) 2022.04.06

+ Recent posts