https://github.com/childe/hangout/releases
https://github.com/RickyHuo/hangout-output-clickhouse/releases
cd /opt
mkdir hangout
cd hangout
wget https://github.com/childe/hangout/releases/download/v0.4.0/hangout-dist-0.4.0-release-bin.zip
unzip hangout-dist-0.4.0-release-bin.zip
cd modules
wget https://github.com/RickyHuo/hangout-output-clickhouse/releases/download/0.0.8/hangout-output-plugins-clickhouse-0.0.8-jar-with-dependencies.jar
cd ../
vi hangout.yml
inputs:
- Kafka:
topic:
mysql2kafka: 0
codec: json
consumer_settings:
bootstrap.servers: kafka:9092
value.deserializer: org.apache.kafka.common.serialization.StringDeserializer
key.deserializer: org.apache.kafka.common.serialization.StringDeserializer
group.id: hangout
outputs:
- com.sina.bip.hangout.outputs.Clickhouse:
host: server1:8123
username:
password:
database: abc
table: bbs
fields: ['fid', 'name', 'rank', 'threads', 'todayposts', 'todaythreads', 'brief']
bulk_size: 500
bin/hangout -f hangout.yml
https://blog.csdn.net/bluetjs/article/details/80325820
签名:这个人很懒,什么也没有留下!