profile
알고리즘 / 기술 스택 / CS

Kafka Partition 정보와 java volatile

나는 Spring kafka를 사용하며, KafkaMessageListenerContainer를 직접 설정해주고 선언해서 사용하고 있다. (다른 사용법으로도 Spring Context 객체를 이용해 KafkaMessageListenerContainer를 접근할 수 있다

2022년 2월 10일
·
0개의 댓글

Kafka Consumer Fetch Interval 관련 설정

spring.kafka.consumer 하위 설정1) fetch-min-bytes : Record를 fetch 해올 최소 용량. Record를 너무 잘게 가져오지 않도록 설정2) fetch-max-wait-ms : Record를 fetch 하는 걸 기다리는 최대 시간.

2022년 1월 12일
·
0개의 댓글
post-thumbnail

Kafka Consumer Rebalancing 관리

Kafka Consumer Group Coodinator는 Kafka Consumer 연결을 관리하면서, Consumer로부터, session-timeout-ms 이내에 heartbeat를 한번도 받지 못하면, Consumer가 죽었다고 생각해 Rebalancing

2022년 1월 7일
·
0개의 댓글

프로그래밍스 > 입국심사

https://programmers.co.kr/learn/courses/30/lessons/43238알고리즘은 거진 모든 경우의 수를 탐색하되, 그 중 가능하며, 가장 효율적인 방법을 찾아서 선택해야 한다.실제 사람이 해결하는 방법을 따라가며 해결해야할 수도

2021년 10월 6일
·
0개의 댓글

다단계 칫솔 판매

import java.util.\*;class Solution { public int\[] solution(String\[] enroll, String\[] referral, String\[] seller, int\[] amount) { int\[]

2021년 10월 3일
·
0개의 댓글

Cassandra OOM 발생 원인 분석

카산드라를 버전 업 (3.0)하면서, memtable_allocation_type을 offheap-buffers로 변경했다.특정 테이블의 특정 컬럼 타입을 frozen -> array<map<~>>로 변경 \-> 이게 좀 치명적인 문제였음.memtabl

2021년 9월 24일
·
0개의 댓글