Sticky
-
[Kafka] 11. Parition Assignment Strategy개발/Kafka 2022. 8. 9. 15:37
Parition Assignment Strategy Conumser의 설정 파리미터 중에서 partition.assingment.strategy로 할당 방식을 조정할 수 있다. org.apache.kafka.clients.consumer.RangeAssignor : Topic별로 작동하는 Default Assignor org.apache.kafka.clients.consumer.RoundRobinAssignor : Round Robin 방식으로 Consumer에게 Partition을 할당한다. org.apache.kafka.clients.consumer.StickyAssginor : 최대한 많은 기존 Partition 할당을 유지하면서 최대 균형을 이루는 할당을 보장한다. org.apache.kafka...
-
[Kafka] - 4. Producer개발/Kafka 2022. 8. 4. 16:10
Producer Producer는 Kafka에 Data를 넘겨주는 역할을 한다. ( Message = Data = Record = Event ) 1. Header(metadata) Topic, Partition, timestamp.. etc 2. Body Key-value Kafka는 Data를 Byte Array로 저장한다. Byte Array로 저장하기 위하여 Produce는 Data를 Serialize하며, Consumer는 Data를 확인 하기 위해 deserialze해야 한다. Key-value용 Serializer를 설정하기 위해서 아래 코드와 같이 사용한다고 한다. Properties props = new Properties(); props.put("bootstrap.servers", "lo..