- 전체보기(9)
- kafka(5)
- consumer(4)
- static membershop(1)
- Spring(1)
- Listener(1)
- member(1)
- assigned(1)
- Event(1)
- id(1)
- outbound(1)
- linux(1)
- webflux(1)
- getAssignedPartitions(1)
- producer(1)
- offset(1)
- Querydsl(1)
- rebalancing(1)
- postgres(1)
- delete(1)
- value(1)
- State(1)
- window(1)
- reset(1)
- topic(1)
- r2dbc(1)
- 명령어(1)
- Fetch(1)
- partitions(1)
- interval(1)
- time(1)
Spring Webflux & QueryDSL
Spring Webflux에 dynamic query를 사용하기 위해서 QueryDSL을 붙히려고 했다. Reactive에 맞는 것을 붙히기 위해 r2dbc & QueryDSL을 채택해서, https://github.com/infobip/infobip-
Kafka 명령어 모음 (Window & Linux)
Window 버전topic : test, consumer-group: Test\-- Kafka 수행 위치 (kafka 설치 경로)cd C:\\monitoring\\kafka\-- ZK SERVER START.\\bin\\windows\\zookeeper-server-s
Kafka의 offset reset
offset 은 long type으로 할당해서 사용한다. offset은 offset retention period 설정을 (default 7 days) 통해 주기적으로 0으로 초기화한다. 만약, Long.MAX_VALUE 범위를 넘어가면 어떻게 될까? → offse
Kafka Partition 정보와 java volatile
나는 Spring kafka를 사용하며, KafkaMessageListenerContainer를 직접 설정해주고 선언해서 사용하고 있다. (다른 사용법으로도 Spring Context 객체를 이용해 KafkaMessageListenerContainer를 접근할 수 있다
Kafka Consumer Fetch Interval 관련 설정
spring.kafka.consumer 하위 설정1) fetch-min-bytes : Record를 fetch 해올 최소 용량. Record를 너무 잘게 가져오지 않도록 설정2) fetch-max-wait-ms : Record를 fetch 하는 걸 기다리는 최대 시간.
Kafka Consumer Rebalancing 관리
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\[]
Cassandra OOM 발생 원인 분석
카산드라를 버전 업 (3.0)하면서, memtable_allocation_type을 offheap-buffers로 변경했다.특정 테이블의 특정 컬럼 타입을 frozen -> array<map<~>>로 변경 \-> 이게 좀 치명적인 문제였음.memtabl