reiseburo
/
beetle
mirror of https://github.com/reiseburo/beetle
1
0
Fork 0
Code Issues Releases Wiki Activity

Sketch out a discovery-less API

This commit is contained in:
R. Tyler Croy 2015-09-03 14:47:02 -07:00
parent b251f98600
commit aeead3c2d3
No known key found for this signature in database
GPG Key ID: 1426C7DC3F51E16F
1 changed files with 11 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
README.adoc
View File

@ -1,5 +1,7 @@
= Beetle
image:https://travis-ci.org/reiseburo/beetle.svg?branch=master["Build Status", link="https://travis-ci.org/reiseburo/beetle"]
Beetle is a somewhat higher level Java API on top of the client libraries
distributed distributed with link:http://kafka.apache.org[Apache Kafka]. The
goal of this library is not to replace the use of those libraries, but to wrap
@ -51,6 +53,15 @@ LocateBrokers.zookeeper("localhost:2181")
----
.ZookeeperlessConsumer.java
[source, java]
----
Broker.just('localhost:6667')
.map(broker -> TopicSubscription("some-topic")
.consume(m -> doSomethingWithMessage(m))
.map(m -> m.commitOffset());
----
== Similar Projects
. link:https://github.com/cjdev/kafka-rx[kafka-rx]: Scala-based client which