yogsototh/clj-kafka
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions
135 commits 1 branch 4 tags 157 KiB
Commit graph

135 commits

This branch
This branch
All branches
Author SHA1 Message Date
Alistair Dutton
1cae2a54fd Update URL references to kafka incubator to use the 'real' kafka. 2015-02-18 11:15:18 +00:00
Paul Ingles
61d07ef92f Merge pull request #40 from DayoOliyide/master 
Extend ToClojure protocol to nil
 2015-02-10 09:34:29 +00:00
Dayo Oliyide
b5eca47aa8 Extend ToClojure protocol to nil 2015-02-09 20:02:45 +00:00
Paul Ingles
a776d070ae release 0.2.8-0.8.1.1, adds url and license for clojars promotion 2014-11-19 09:24:45 +00:00
Paul Ingles
18bacba342 add url and license for promotion in clojars 2014-11-19 09:24:10 +00:00
Paul Ingles
c6bb228222 bump release! thanks to @fatlazycat 2014-11-19 09:16:04 +00:00
Paul Ingles
d2173cbe8e style tweak 2014-11-19 09:15:29 +00:00
Graham Berks
1a695580a4 Upgraded kafka to 0.8.1.1 and zkclient to 0.4 2014-11-18 21:26:17 +00:00
Paul Ingles
678caa5b2c Merge pull request #36 from MastodonC/add-license-file 
Add EPL License file.
 2014-10-23 18:18:10 +01:00
Neale Swinnerton
c9943ecb5f Add EPL License file. 2014-10-23 18:04:32 +01:00
Paul Ingles
93a89f41bb Merge branch 'master' of github.com:pingles/clj-kafka 
Conflicts:
	README.md
 2014-05-14 10:22:32 +01:00
Paul Ingles
345d8ba0ff add clj-kafka latest version badge to README 2014-05-14 10:22:06 +01:00
Paul Ingles
d8848eb275 Merge pull request #28 from l1x/master 
Updating README.md
 2014-05-14 10:18:21 +01:00
Istvan Szukacs
89dd4f95ae Updating README.md 2014-05-13 11:19:21 -07:00
Paul Ingles
c397a8ff1b release 0.2.6 2014-05-09 17:45:14 +01:00
Paul Ingles
3cf86987bb use create-all when creating the node 2014-05-09 17:44:57 +01:00
Paul Ingles
031b80f05d bump clj-kafka release 2014-05-09 11:58:48 +01:00
Paul Ingles
6b506b692e add committed-offset and set-offset! to allow offsets to be manipulated/read directly 2014-05-09 11:57:41 +01:00
Paul Ingles
96275316e9 release with zookeeper partitions fn 2014-05-07 17:50:10 +01:00
Paul Ingles
308c76a864 add partitions fn to access partition/replica data 2014-05-07 17:49:06 +01:00
Paul Ingles
ddb0a77391 add topic-offset to simple consumer: can be used to determine earliest offset available too 2014-05-01 15:23:56 +01:00
Paul Ingles
5b7afa5723 add thanks to yourkit in README 2014-04-30 10:01:42 +01:00
Paul Ingles
52032432b9 add number of consumer threads to zk consumer 2014-04-28 14:12:41 +01:00
Paul Ingles
8acfb69df6 add broker-list to help build metadata.broker.list strings; change clj-kafka.zk/brokers to return an empty list if zookeeper is available but no kafka brokers are registered. 2014-04-15 13:54:29 +01:00
Paul Ingles
157ca25220 update version in README 2014-04-15 13:25:35 +01:00
Christian Blunden
f0c025d358 Merge pull request #25 from prepor/lazy-iterate 
Do not use iterator-seq with KafkaStream
 2014-03-19 14:27:47 +00:00
prepor
4ff8334299 Do not use iterator-seq with KafkaStream 2014-03-19 22:31:49 +09:00
Paul Ingles
9c19d5df43 Merge pull request #22 from uswitch/unqueued-zk-consumer 
Unqueued zk consumer
 2014-03-05 12:59:19 +00:00
Russell
9a42598d83 Up project version to reflect breaking change 2014-02-24 12:38:03 +00:00
Russell
1723d57e81 Add nrepl-port to gitignore 2014-02-24 12:36:10 +00:00
Russell
ce5cd3eaa2 Remove no longer used pipe implementation 2014-02-24 12:36:10 +00:00
Russell
c606237b1c Remove queue from zk consumer 
To ensure client code has explicit control over the reading of messages
This change removes the ability to listen to multiple topics at once,
as it is not feasible to build this functionality in at the library
level while still giving client code total control and knowledge over
which messages have been read / what the current offset is.
 2014-02-24 12:36:03 +00:00
Paul Ingles
edda2420ae Merge pull request #21 from jpfuentes2/patch-1 
Fix producer example and lein version string
 2013-12-20 07:21:15 -08:00
Jacques Fuentes
ac8ce7090c Fix producer example and lein version string 2013-12-17 16:58:30 -05:00
Paul Ingles
8f2370e6b5 update README to reflect recent changes 2013-12-15 21:01:28 +00:00
Paul Ingles
08611c67c6 release 0.1.2 built with kafka 0.8 final release 2013-12-15 20:56:40 +00:00
Paul Ingles
98a039115b update tests and fix controller fn to extract the controller brokerid 2013-12-15 20:55:05 +00:00
Paul Ingles
ea2992b83b updates for kafka 0.8 release; few changes in zk structures so needs more work 2013-12-15 19:39:27 +00:00
Paul Ingles
d61c4321a4 move metrics-core and zkclient into core dependencies- they're dependencies of kafka that aren't pulled automatically 2013-11-18 13:41:52 +00:00
Paul Ingles
6684e30213 change release number in README 2013-09-19 11:22:14 +01:00
Paul Ingles
62a3ed8ed9 Merge branch '0.8' 
Conflicts:
	README.md
	src/clj_kafka/example/zk.clj
 2013-09-19 11:20:30 +01:00
Paul Ingles
422ccf2b84 update project to use Kafka's 0.8-beta1 release 2013-09-19 11:15:38 +01:00
Paul Lam
7173fd6b11 note 0.8 branch in main readme 2013-07-14 16:26:47 +01:00
Paul Ingles
9e8510d4c9 Merge pull request #17 from rwat/0.8 
fixed typo
 2013-06-13 01:11:59 -07:00
rwat
ed0aa8b919 fixed typo 2013-06-12 16:40:56 -05:00
Paul Ingles
52c61f12c1 await kafka shutdown to minimise errors reported in logs 2013-06-10 20:13:53 +01:00
Paul Ingles
f9a1e978ca map simple consumer messages to-clojure 2013-06-10 15:22:59 +01:00
Paul Ingles
f997dcfcb0 rename :zookeeper-connect in to-clojure to :connect - it is the details to connect directly to the broker 2013-06-10 15:07:33 +01:00
Paul Lam
b543bdcb5a Merge branch '0.8' of github.com:pingles/clj-kafka into 0.8 2013-06-10 13:54:23 +01:00
Paul Lam
e71246eda1 add latest-topic-offset to simple consumer 2013-06-10 13:54:09 +01:00