Spring Webflux에 dynamic query를 사용하기 위해서 QueryDSL을 붙히려고 했다. Reactive에 맞는 것을 붙히기 위해 r2dbc & QueryDSL을 채택해서, https://github.com/infobip/infobip-
Window 버전topic : test, consumer-group: Test\-- Kafka 수행 위치 (kafka 설치 경로)cd C:\\monitoring\\kafka\-- ZK SERVER START.\\bin\\windows\\zookeeper-server-s
offset 은 long type으로 할당해서 사용한다. offset은 offset retention period 설정을 (default 7 days) 통해 주기적으로 0으로 초기화한다. 만약, Long.MAX_VALUE 범위를 넘어가면 어떻게 될까? → offse
나는 Spring kafka를 사용하며, KafkaMessageListenerContainer를 직접 설정해주고 선언해서 사용하고 있다. (다른 사용법으로도 Spring Context 객체를 이용해 KafkaMessageListenerContainer를 접근할 수 있다
spring.kafka.consumer 하위 설정1) fetch-min-bytes : Record를 fetch 해올 최소 용량. Record를 너무 잘게 가져오지 않도록 설정2) fetch-max-wait-ms : Record를 fetch 하는 걸 기다리는 최대 시간.
Kafka Consumer Group Coodinator는 Kafka Consumer 연결을 관리하면서, Consumer로부터, session-timeout-ms 이내에 heartbeat를 한번도 받지 못하면, Consumer가 죽었다고 생각해 Rebalancing
https://programmers.co.kr/learn/courses/30/lessons/43238알고리즘은 거진 모든 경우의 수를 탐색하되, 그 중 가능하며, 가장 효율적인 방법을 찾아서 선택해야 한다.실제 사람이 해결하는 방법을 따라가며 해결해야할 수도
import java.util.\*;class Solution { public int\[] solution(String\[] enroll, String\[] referral, String\[] seller, int\[] amount) { int\[]
카산드라를 버전 업 (3.0)하면서, memtable_allocation_type을 offheap-buffers로 변경했다.특정 테이블의 특정 컬럼 타입을 frozen -> array<map<~>>로 변경 \-> 이게 좀 치명적인 문제였음.memtabl