Kafka with Spring Boot
spring-kafka, library, se, Spring, Boot, applications, Kafka, ke, saath, EASILY, INTEGRATE, ho, sakti, HAIN — @KafkaListener, annotation, se, EK, method, ko, EK, TOPIC, ka, CONSUMER, banaya, ja, sakta hai.
KafkaTemplate, EK, EASY-TO-USE, API, deta hai, MESSAGES, PUBLISH, karne, ke, liye — Spring, Boot, ki, auto-configuration, SAARE, boilerplate, Kafka, CLIENT, setup, ko, HANDLE, kar, leti hai.
@Service
public class OrderEventPublisher {
@Autowired
private KafkaTemplate<String, OrderEvent> kafkaTemplate;
public void publishOrderCreated(OrderEvent event) {
kafkaTemplate.send("order-events", event);
}
}
@KafkaListener(topics = "order-events")
public void handleOrderEvent(OrderEvent event) {
// inventory ko update karo
}- spring-kafka = Kafka, integration, ke, liye, library
- @KafkaListener = method, ko, ek, topic, ka, consumer, banata, hai
- KafkaTemplate = messages, publish, karne, ke, liye, easy, API
@KafkaListener, ke, "groupId" attribute, se, CONSUMER, groups, DEFINE, hote, hain — SAME, group, ke, MULTIPLE, instances, EK, topic, ke, DIFFERENT, PARTITIONS, ko, PARALLEL, mein, PROCESS, karte, hain, load, sharing, ke, liye.
@KafkaListener(topics = "order-events", groupId = "inventory-service-group")JSON, serialization, (JsonSerializer/JsonDeserializer) Spring, Kafka, mein, common, hai — LEKIN, Avro, (schema, registry, ke, saath) LARGE-SCALE, systems, mein, aksar, PREFER, kiya, jaata hai, EFFICIENT, aur, SCHEMA, EVOLUTION, guarantees, ke, liye.