zoukankan      html  css  js  c++  java
  • 使用kafka作为生产者生产数据_到_hbase

    配置文件:

    agent.sources = r1
    agent.sinks = k1
    agent.channels = c1

    ## sources config
    agent.sources.r1.type = org.apache.flume.source.kafka.KafkaSource
    agent.sources.r1.kafka.bootstrap.servers = 192.168.80.128:9092,192.168.80.129:9092,192.168.80.130:9092
    agent.sources.r1.kafka.topics =1713
    agent.sources.r1.migrateZookeeperOffsets =false
    agent.sources.r1.kafka.consumer.timeout.ms = 1000
    #agent.sources.r1.kafka.consumer.group.id = consumer-group

    ## channels config
    agent.channels.c1.type = memory
    agent.channels.c1.capacity = 1000
    agent.channels.c1.transactionCapacity = 100
    agent.channels.c1.byteCapacityBufferPercentage = 60
    agent.channels.c1.byteCapacity = 1280
    agent.channels.c1.keep-alive = 60


    # Describe the sink
    agent.sinks.k1.type =asynchbase //sink类型到hbase
    agent.sinks.k1.table = tb_words3 //表
    agent.sinks.k1.columnFamily = words //列族
    agent.sinks.k1.serializer.payloadColumn=wd //列名
    agent.sinks.k1.serializer =org.apache.flume.sink.hbase.SimpleAsyncHbaseEventSerializer

    # Use a channel which buffers events in memory
    agent.channels.c1.type = memory
    agent.channels.c1.capacity = 1000
    agent.channels.c1.transactionCapacity = 100

    # Bind the source and sink to the channel
    agent.sources.r1.channels = c1
    agent.sinks.k1.channel = c1

    成就人
  • 相关阅读:
    获取CheckBox的Text值
    动态绑定数据至Html Table
    二次事件并细化功能
    ASP.NET MVC的JavaScriptResult
    Google Earth 8.0
    ASP.NET MVC的ContentResult
    ASP.NET MVC使用input标签上传文件
    处理动态SQL语句的参数
    Infor SyteLine如何快速锁定用户
    执行git push出现"Everything up-to-date"
  • 原文地址:https://www.cnblogs.com/pingzizhuanshu/p/9102587.html
Copyright © 2011-2022 走看看