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으로 보낼지 결정
'~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 |