Kafka
-
Kafka idleBetweenPolls를 활용한 의도적 메시지 처리 지연 구현(Spring)Kafka 2025. 1. 14. 00:01
0. 케이스Kafka가 메시지를 처리하는 속도는 메시징 시스템 중에서 가장 빠른 편이다.더보기KafkaPulsarRabbitMQ(Mirrored)Peak Throughput(MB/s)605MB/s305MB/s38MB/sp99 Latency(ms)5 ms(200 MB/s load)25 ms(200 MB/s load)1 ms*(reduced 30 MB/s load)https://www.confluent.io/ko-kr/blog/kafka-fastest-messaging-system/ Benchmarking RabbitMQ vs Kafka vs Pulsar PerformanceA complete benchmark of RabbitMQ, Kafka, and Pulsar to determine performanc..
-
Kafka Producer 커스터마이징하기 #2Kafka 2024. 5. 11. 06:16
다중 인터페이스를 정의하는 경우https://sillydev.tistory.com/72 Kafka Producer 커스터마이징하기 #10. Maven Dependency 정의 org.springframework.kafka spring-kafka 1. Bean 주입@Configurationpublic class KafkaProducerConfig { @Value("${spring.kafka.bootstrap-servers}") private String bootstrapServers; // Kafka Broker host (VM argument or propertiessillydev.tistory.com 이전 글을 통해 Kafka Producer Bean 을 주입하는 방법에 대해 정리했다. 그런데 전송하고..
-
Kafka Producer 커스터마이징하기 #1Kafka 2024. 5. 11. 04:13
0. Maven Dependency 정의 org.springframework.kafka spring-kafka 1. Bean 주입@Configurationpublic class KafkaProducerConfig { @Value("${spring.kafka.bootstrap-servers}") private String bootstrapServers; // Kafka Broker host (VM argument or properties 값을 사용) @Bean public ProducerFactory producerFactory() { Map configProps = new HashMap(); configProps.put(ProducerConfig..