Code Monkey home page Code Monkey logo

flume-ng-kafka-sink's Introduction

flume-ng-kafka-sink

This project is used for flume-ng to communicate with kafka 0.8.0.

Configuration of Kafka Sink

agent_log.sinks.kafka.type = org.apache.flume.sink.kafka.KafkaSink
agent_log.sinks.kafka.channel = all_channel
agent_log.sinks.kafka.topic = all
agent_log.sinks.kafka.serializer.class = kafka.serializer.StringEncoder
agent_log.sinks.kafka.metadata.broker.list = [kafka_producer_host_name:port]

# If producer.type == async
agent_log.sinks.kafka.batch.num.messages = 200 #optional
agent_log.sinks.kafka.producer.type = async

# If producer.type == sync
agent_log.sinks.kafka.syncbatchsize = 200
agent_log.sinks.kafka.producer.type = sync
agent_log.sinks.kafka.request.required.acks = 1 #optional

Install as a flume plugin

  • Compile this repo
  • Copy the uberjar to [whereever flume is]/lib. Example, /usr/lib/flume/lib.

Run it

  • Run flume

  • flume-ng agent --conf /etc/flume/conf --conf-file /etc/flume/conf/flume-kafka-vagrant-sink.conf --name a1 -Dflume.root.logger=INFO,console

  • In another terminal

  • telnet localhost 444444

  • start typing away

Special Thanks

flumg-ng-rabbitmq. Thanks to Jeremy Custenborder.

flume-ng-kafka-sink's People

Watchers

avatar avatar avatar

Recommend Projects

  • React photo React

    A declarative, efficient, and flexible JavaScript library for building user interfaces.

  • Vue.js photo Vue.js

    🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.

  • Typescript photo Typescript

    TypeScript is a superset of JavaScript that compiles to clean JavaScript output.

  • TensorFlow photo TensorFlow

    An Open Source Machine Learning Framework for Everyone

  • Django photo Django

    The Web framework for perfectionists with deadlines.

  • D3 photo D3

    Bring data to life with SVG, Canvas and HTML. 📊📈🎉

Recommend Topics

  • javascript

    JavaScript (JS) is a lightweight interpreted programming language with first-class functions.

  • web

    Some thing interesting about web. New door for the world.

  • server

    A server is a program made to process requests and deliver data to clients.

  • Machine learning

    Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.

  • Game

    Some thing interesting about game, make everyone happy.

Recommend Org

  • Facebook photo Facebook

    We are working to build community through open source technology. NB: members must have two-factor auth.

  • Microsoft photo Microsoft

    Open source projects and samples from Microsoft.

  • Google photo Google

    Google ❤️ Open Source for everyone.

  • D3 photo D3

    Data-Driven Documents codes.