[Apache Kafka Application Programming] From concepts to consumers, producers, connects, and streams!

안녕하세요 prod 이후 long-end-offset은 늘어났지만 lag이 줄어들지 않는데 이런경우 어떻게 처리해야하나요?

주키퍼라는 애플리케이션은 2026년도 기준 카프카 4.0 이후 버전이라 필요가 없다고 하는데요.현재 강의의 버전과 2026년도 현재버전에서 레거시하게 사라진 것과

1. retries가 Integer.MAX_VALUE로 설정되는 이유?아래와 같은 이유로 retries가 Integer.MAX_VALUE로 설정되는 것인지 궁

안녕하세요!이번에 카프카를 처음 접해본 초보 개발자입니다.이번 카프카를 공부하면서 프로젝트로 여러 사람들이 채팅방에서 채팅하는 기능을 만들어보고싶은데요..

메시지 키가 있을 경우 전달되는 파티션이 변경되는 것을 방지하기 위해 충분히 큰 파티션으로 생성을 해야한다. <p style="text-

안녕하세요 KTable은 키가 없는 레코드에 대해서 무시하는 것이 맞을까요?

안녕하세요실무에서 Kafka 컨슈머 애플리케이션을 구현할 때 폴링을 위해 while (true) 루프를 사용하나요? 그렇다고 한다면 실제

안녕하세요.onPartitionRevoked() 메서드에 대한 아래 설명을 보고 몇 가지 의문이 생겨 질문드립니다.<blockquo

안녕하세요.카프카 클러스터 규모를 추산하던 중 감당 가능한 토픽/파티션 수가 궁금하여 질문드립니다.&nb

--reset-offsets --to-earliest 같은 커맨드를 할 때 제일 처음으로 오프셋이 바뀌는데, 만약 파티션이 여러개일경우에는 어떻게 하나요? 특정파티션만 오프셋을 조절할 수 있는 커맨드도 있나요?

맥북 M1이고 jdk version "1.8.0_402" 입니다.KStreamJoinKTable 실행시 오류가 나서 order_join 결과값에 아무것도 나오지

auto.commit.interval.ms 옵션의 시간이 길게 설정된 경우 강제로 서버가 종료되는 문제 발생 시 commit 누락으로 인한 중복 처리 문제가 발생할 수 있을까요?

안녕하세요 원영님, 강의를 듣다가 궁금한 점이 생겼습니다.1-1. 하나의 파티션은 여러 컨슈머에 할당될 수 없다고 하셨는데 엄밀히 말하면 '동일 컨슈머 그룹' 기준으로 여러 컨슈머에 할당될 수 없는게 맞을

안녕하세요 좋은 강의 감사합니다.말씀주신 카프카의 중요 개념적인 것들 (컨슈머, 프로듀서 등등) 이 자바에 국한된 것이라고 하셨었잖아요.<p style="

7강 > 컨슈머의 안전한 종료에서컨슈머 애플리케이션의 안전한 종료를 위해서 shutdownThread 을 활용한다고 하셨는데요..개념을 설명하실때에는 컨슈머 그룹내 특정 컨슈머에 대한 문제 발생시 wakeup을 통하여 컨슈머를 종료

bin/zookeeper-server-start.sh config/<a target="_

섹션 10. 커스텀 소스 커넥터 22:49 보고있는데요. poll 함수의 상단에 Thread.sleep(1000) 을 하고있는데 왜 1초의 딜레이를 주는지 궁금합니다.

안녕하세요. 처리량을 늘리기 위해서 파티션을 늘리고 컨슈머를 늘려야한다고 설명하셨는데요 파티션을 늘린다다는것은 카프카 설정에서 설정할 수 있을 것 같은데.. 컨슈머를 늘린다는것은 eks 에서 본

<img src="https://cdn.inflearn.com/public/files/posts/042a8546-64d2-47f6-b669-5b5e2247fd1a/b9b9dd6e-5f67-4714-b355-1560d77da440.webp" media-type="img"

안녕하세요. 개발자님 실시간 이미지 및 동영상 을 kafka 로 전달 전처리 이후 다시 kafka로 전송 하는 방식이 긍금합니다.IOT 장비(카메라) 로 이미지 및 동영상으로 받아 kafka 전달 받아 전처리