1. golang 설치
$ brew install go
2. burrow clone from github
$ git clone https://github.com/linkedin/Burrow.git
3. go build, install
$ cd to the source directory.
$ go mod tidy
$ go install
3. run
$ $GOPATH/bin/Burrow --config-dir=/path/containing/config
버로우를 실행할 때 주의할점은 --config-dir은 말그대로 디렉토리를 설정해야한다. 파일을 설정하면 안된다. burrow.toml이 포함된 디렉토리를 설정한다.
로컬호스트에서 카프카, 주키퍼를 실행할 경우 아래와 같이 burrow.toml을 설정한다.
[general]
[logging]
level="info"
[zookeeper]
servers=[ "localhost:2181"]
[client-profile.local]
client-id="burrow-local"
kafka-version="2.0.0"
[cluster.local]
class-name="kafka"
servers=[ "localhost:9092" ]
client-profile="local"
topic-refresh=120
offset-refresh=30
[consumer.local]
class-name="kafka"
cluster="local"
servers=[ "localhost:9092" ]
client-profile="local"
group-denylist="^(console-consumer-|python-kafka-consumer-|quick-).*$"
group-allowlist=""
[httpserver.default]
address=":8000"
[storage.default]
class-name="inmemory"
workers=20
intervals=15
expire-group=604800
min-distance=1
반응형
'빅데이터 > Kafka' 카테고리의 다른 글
local kafka single broker 띄우기 with 도커 (0) | 2021.03.05 |
---|---|
특정 시점(날짜+시간)의 레코드부터 가져오도록 설정하기. (2) | 2021.03.03 |
아파치 카프카를 데이터 레이크로 사용할 수 있을까? (1) | 2021.02.25 |
카프카 토픽의 오프셋 최대 크기는 얼마일까? (0) | 2020.11.17 |
카프카 커넥터 빌드시 JDK11이 아닌 JDK8로 그래들 빌드해야합니다. (2) | 2020.11.02 |
failed authentication due to: Authentication failed during authentication due to invalid credentials with SASL mechanism SCRAM-SHA-256 (0) | 2020.10.23 |