기본 설정 gradle에서 아래와 같이 dependencies 지정함으로써 kafka client 라이브러리 사용 가능 /* * This file was generated by the Gradle 'init' task. * * This generated file contains a sample Java application project to get you started. * For more details on building Java & JVM projects, please refer to https://docs.gradle.org/8.12/userguide/building_java_projects.html in the Gradle documentation. */plugins { // Apply ..
브로커- 카프카 클라이언트와 데이터를 주고받기 위한 주체 - 데이터를 분산 저장하여 fault tolerance 유지해주는 애플리케이션- 실 운영 환경에서는 3대 이상의 브로커를 1개의 클러스터로 묶어 운영해야 함 데이터 저장, 전송 - 프로듀서가 브로커로 데이터를 전송 - 브로커는 프로듀서가 요청한 토픽의 파티션에 데이터를 저장- 컨슈머가 데이터를 요청하면 브로커는 파티션에 저장된 데이터를 전송 일반적인 메시지 큐잉 서비스는 큐에 저장된 데이터 전송하면 해당 메시지는 삭제되지만, kafka는 파일 시스템을 이용하기 때문에 설정한 유지 기간 (retention.ms 등) 동안 파일 시스템에 메시지가 저장됨. 하지만 페이지 캐시를 사용해 디스크 입출력 속도를 높혀 파일 시스템을 통한 I/O에 대한 속도 ..