카프카 트랜잭션 생산자 READ_COMMITTED는

Question

나는 카프카의 새로운 트랜잭션 생산을 테스트하기 위해이 간단한 프로그램을 작성 중단에도 불구하고 기록을 보여줍니다

--- ~ » kafka-console-consumer --bootstrap-server localhost:9092 \ 
     --topic topic \ 
     --from-beginning \ 
     --consumer-property isolation.level=read_committed 

world 

무엇이 누락 되었습니까? 콘솔 소비자와 read_committed을 사용하려면

Answer 1

, 당신은 --isolation-level 옵션을 지정해야합니다 read_uncommitted에

kafka-console-consumer.sh --bootstrap-server localhost:9092 \ 
--topic topic --from-beginning --isolation-level=read_committed 

이 옵션 그렇지 않으면 기본값을하고 --consumer-property를 통해 전달하는 값을 대체합니다.