이전 강의에서는 Flux가 무엇인지에 대해 주로 알아봤었다. Flux를 언제, 어떻게 생성해야 할까? create를 사용한 Flux 생성 Flux.create(fluxSink -> { fluxSink.next(1); fluxSink.next(2); fluxSink.complete(); }).subscribe(...) 처럼 cre
카프카를 실제 운영환경에서 사용하다 보면 마주치게 되는 몇 가지 이슈가 있다. 오늘은 그 중 컨슈머 그룹의 파티션 리밸런싱에 대해 좀 정리해봤다. https://kafka.apache.org/0101/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html 컨슈머 그룹 리밸런