Backend/Kafka (2) 썸네일형 리스트형 [Kafka] Code analysis for sending record in producer Let's analyze code where data is sent in a producer. Call back initialization private Future doSend(ProducerRecord record, Callback callback) { // Append callback takes care of the following: // - call interceptors and user callback on completion // - remember partition that is calculated in RecordAccumulator.append AppendCallbacks appendCallbacks = new AppendCal.. [Kafka] Code analysis for topic creation Let me break down kafka code when creating a topic, especially looking at main function. This code is part of the Apache Kafka server-side logic for creating topics. It handles topic creation by validating configurations and policies, assigning partitions and replicas, and then creating the topic. It is from a function of createTopics at ZkAdminManager.scala.Parameters /** * Create topics and.. 이전 1 다음