You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Milind Parikh <mi...@gmail.com> on 2012/10/14 07:34:02 UTC
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
Re: Erlang library for Kafka 0.7.x
Posted by Neha Narkhede <ne...@gmail.com>.
Looks great, thanks for sharing !
-Neha
On Sat, Oct 13, 2012 at 10:34 PM, Milind Parikh <mi...@gmail.com> wrote:
> 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