Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # dev >> Erlang library for Kafka 0.7.x


Copy link to this message
-
Erlang library for Kafka 0.7.x
https://github.com/milindparikh/erlkafka.git

erlkafka is a kafka client written in erlang.

erlkafka provides seven core functions

    produce                        %% native kafka produce request
    multi_produce                  %% native kafka multi_produce request
    fetch                          %% native kafka fetch request
    multi_fetch   %% native kafka multi_fetch request
    offset   %% native kafka offset request
    get_list_of_brokers            %% conditional zookeeper dependent
list of brokers
    get_list_of_broker_partitions  %% conditional zookeeper dependent
list of broker partitions
                                   %% for a topic

erlkafka is available under two different licenses. LGPL or the BSD license.
erlkafka current verion : 0.5.0

It requires ezk (https://github.com/infinipool/ezk.git) for auto discovery.

   {enable_kafka_autodiscovery, true} in erlkafka_app.app is the switch to
   turn auto discovery on.
   if {enable_kafka_autodiscovery, false) then
         application:start(erlkafka_app)   is sufficient

   if {enable_kafka_autodiscovery, true) then
         application:start(ezk)
         application:start(erlkafka_app)   is required
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB