Flatmap → map 으로 메세지 개수를 조정 한뒤 아래와 같은 테스트를 진행 하였다.
1, Agent 에서 메세지당 KB 를 조정하여 AGENT 의 CPU 와 KSTREAM 의 전체 Throuput 을 관찰하는 것이 목적이다.
Partition 1 - Thread 1 - Sleep 0 기준 테스트
2.같은 Thruput 을 Partition3 = thread 3 option 에서 관찰
3.2와같은 환경에서 timesleep = 30ms 조건에서 관찰
4. sleep time 당 Throghput in(주황) 과 CPu 점유율(파랑)
'spark,kafka,hadoop ecosystems > apache.kafka' 카테고리의 다른 글
| 1 topic vs multi topic (0) | 2018.11.21 |
|---|---|
| zookeeper (0) | 2018.11.20 |
| kafka - partitions (0) | 2018.11.20 |
| kafka log 정책 (0) | 2018.11.20 |
| kafka manager (0) | 2018.11.20 |