hangout 部署 - kafka2clickhouse clickhouse kakfa


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


签名:这个人很懒,什么也没有留下!
最新回复 (0)
返回