<div id="readability-page-1" class="page"><div id="kakaoContent">

                <div>
                                            <p><a href="/m/category/%EB%A6%AC%EB%88%85%EC%8A%A4%20%EC%84%9C%EB%B2%84">리눅스 서버</a></p><h2>클라이언트 설치 없이 카프카 브로커와 통신하기 - Kafkacat</h2>
                    <p><cite>
                        <span>chancethecoder</span>
                    </cite>
                </p></div>
                <p><time>2020. 11. 29. 19:44</time>
                    <span>
                        
                                                    <a href="#comment" onclick="Utils.smoothScroll(this);return false">
                                
                            </a>
                        
                                                    <span id="title_daumlike">
                                
                                <span id="mobile-reaction"></span>
                                
                            </span>
                                            </span>
                </p>

                
                <div>
                    <p><a href="https://kafka.apache.org/">카프카</a>를 사용하는 개발자라면 로컬 혹은 서버에서 브로커와 직접 통신을 해야하는 경우가 있습니다. 이 때 별도 설치 없이 명령어 한 줄로 편리하게 쓸 수 있는 도구인 <a href="https://github.com/edenhill/kafkacat/">Kafkacat</a>을 소개해드리겠습니다.</p>
<h4>요구사항</h4>
<ul>
<li>Docker</li>
</ul>
<h4>사용법</h4>
<p>자세한 문법은 <a href="https://github.com/edenhill/kafkacat/#examples">해당 링크</a>를 참조하시기 바랍니다.</p>
<ul>
<li><p>토픽 목록 출력 </p>
<pre><code>docker run --tty --interactive \
  confluentinc/cp-kafkacat \
  kafkacat -b kafka:9092 \
  -L</code></pre>
</li>
<li><p>토픽 메세지 컨슈밍</p>
<pre><code>docker run --tty --interactive \
  confluentinc/cp-kafkacat \
  kafkacat -b kafka:9092 \
  -t topic_name \
  -C</code></pre>
</li>
<li><p>토픽 메세지 포맷 지정 및 컨슈밍</p>
<pre><code>docker run --tty --interactive \
  confluentinc/cp-kafkacat \
  kafkacat -b kafka:9092 \
  -t topic_name \
  -f '\nKey (%K bytes): %k\t\nValue (%S bytes): %s\n\Partition: %p\tOffset: %o\n--\n' \
  -K: \
  -C</code></pre>
</li>
<li><p>토픽에 메세지 프로듀싱</p>
<pre><code>docker run --interactive \
  confluentinc/cp-kafkacat \
  kafkacat -b kafka:9092 \
  -t topic_name \
  -K: \
  -P &lt;&lt;EOF
1:FOO
2:BAR
EOF</code></pre>
</li>
</ul>

                                                            
                    
											
					
                    
                    
                </div>

                                    
                
                
                                    
                
                


                

                                    
                
                
            </div></div>

생각나는대로 적어본다.

카프카를 사용하는 개발자라면 로컬 혹은 서버에서 브로커와 직접 통신을 해야하는 경우가 있습니다. 이 때 별도 설치 없이 명령어 한 줄로 편리하게 쓸 수 있는 도구인 Kafkacat을 소개해드리겠습니다.
요구사항
Docker
사용법
자세한 문법은 해당 링크를 참조하시기 바랍니다.
토픽 목록 출력 
docker run --tty --interactive \
  confluentinc/cp-kafkacat \
  kafkacat -b kafka:9092 \
  -L
토픽 메세지 컨슈밍
docker run --tty --interactive \
  confluentinc/cp-kafkacat \
  kafkacat -b kafka:9092 \
  -t topic_name \
  -C
토픽 메세지 포맷 지정 및 컨슈밍
docker run --tty --interactive \
  confluentinc/cp-kafkacat \
  kafkacat -b kafka:9092 \
  -t topic_name \
  -f '\nKey (%K bytes): %k\t\nValue (%S bytes): %s\n\Partition: %p\tOffset: %o\n--\n' \
  -K: \
  -C
토픽에 메세지 프로듀싱
docker run --interactive \
  confluentinc/cp-kafkacat \
  kafkacat -b kafka:9092 \
  -t topic_name \
  -K: \
  -P <<EOF
1:FOO
2:BAR
EOF

클라이언트 설치 없이 카프카 브로커와 통신하기 - Kafkacat

댓글