Home | About | Sematext search-lucene.com search-hadoop.com
 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