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
Paul Ingles
fe273bf32c
move expectations dependency into the dev profile
2013-06-10 12:46:08 +01:00
Paul Lam
6a547f5616
get topics from zk
2013-06-10 12:13:03 +01:00
Paul Lam
27ba361517
zk/controller to get leader node
2013-06-10 11:56:49 +01:00
Paul Lam
c46c916ca0
zk ns to hold zookeeper methods
2013-06-10 11:36:37 +01:00
Paul Lam
602be6f061
add :broker-id for to-clojure on Broker
2013-06-10 11:23:18 +01:00