시도는 충분히 아름답다ㅎ   kafka는 scalar와 java로 만들어서 jvm 위에서 동작한다던데, 성능적인 요인을 따라 잡기 위한 zero copy나 Sequential IO 같은게 될지는 모르겠다. 아직은 Kafka의 내부 원리를 공부하는 단계이다.   1. hello 라는 토픽에 'hello world!' 문자열을 Produce한다.해당 토픽에 컨슈머 그룹에 적용되지 않으면 자동으로 default라는 그룹에 속한다. 2. news 라는 토픽에 'this is consumed' 문자열을 Produce한다.main.cpp에서 이미 news 토픽을 구독하는 Consumer를 생성했고, 'group1' 이라는 컨슈머 그룹에 등록시켰다. 3. 따라서 성공적으로 소비한 뒤, Consumed message를..