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

100 commits

This branch
This branch
All branches
Author SHA1 Message Date
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
Paul Lam
7978821026 topic-meta-data pass in topic and returns brokers with that topic 2013-06-10 11:20:00 +01:00
Paul Lam
dd1cdeeb86 mv test ns consumer.clj into consumer/zk.clj 2013-06-10 10:47:18 +01:00
Paul Lam
2f24376609 use zookeeper-port in tests 2013-06-10 09:23:07 +01:00
Paul Ingles
10c22c7d21 update the README following the 0.8 changes over the weekend 2013-06-10 09:17:53 +01:00
Paul Ingles
4baa38f97d add some type hints to avoid reflection in some key fns 2013-06-09 16:17:36 +01:00
Paul Ingles
b9d3c7a069 update travis-ci to run only expectations 2013-06-09 09:18:19 +01:00
Paul Ingles
6e19e4c8b3 fix travis-ci config to run lein2 command 2013-06-09 08:41:57 +01:00
Paul Ingles
d9ab7ba672 update travis-ci to run both tests and expectations; started rewriting tests as expectations 2013-06-09 08:39:46 +01:00
Paul Ingles
1d92367158 deleting empty test ns 2013-06-09 08:24:15 +01:00
Paul Ingles
5ba3d9b67b delete MessageValue protocol- clients should know whether they're providing a byte array or not and they can implement their own protocols. 2013-06-09 08:17:48 +01:00
Paul Ingles
24f182c824 change producer send-message to receive a KeyedMessage rather than topic/value; rename keyed-message to just message and have pulled message-value out of send-message: clients should know whether they're providing a byte array or not. 2013-06-09 08:15:03 +01:00
Paul Ingles
b373042058 delete ToClojure extension for ByteBuffer: didn't make any sense given it just extracts the bytes 2013-06-09 08:01:47 +01:00
Paul Ingles
f75c4b339a change log4j to append to ./logs/kafka.log; tidy the zk consumer test 2013-06-09 07:51:34 +01:00
Paul Ingles
257c25293d remove println; move test broker config into a Var 2013-06-09 07:43:24 +01:00
Paul Ingles
76ede151a4 pull paren up 2013-06-08 11:52:07 +01:00
Paul Ingles
1e014986c5 refactor test.utils/with-test-broker to receive config map specifying ports + topic name 2013-06-08 11:49:52 +01:00
Paul Ingles
be2cd0329f add queue-capacity option for zookeeper messages: can be used to limit LinkedBlockingQueue queue size with large messages 2013-06-07 22:11:42 +01:00
Paul Ingles
84c813ae48 add message piping back; to-clojure conversion to KafkaMessage added by default 2013-06-07 22:03:11 +01:00
Paul Ingles
57a9f17dfa rename with-broker to with-test-broker 2013-06-07 21:55:11 +01:00
Paul Ingles
ec1fb0671c rename MessagePayload to MessageValue 2013-06-07 21:10:37 +01:00
Paul Ingles
6437dcd18d delete unused to-clojure definition 2013-06-07 21:09:02 +01:00
Paul Ingles
8643566f5c add log4j properties to reduce logging in dev/test; delete tmp directory before test run too 2013-06-07 20:58:23 +01:00
Paul Lam
cd525fa6bd fix hanging param from merge 2013-06-07 16:36:42 +01:00
Paul Lam
20683d7e18 type hint consumer.simple 2013-06-07 16:35:48 +01:00
Paul Lam
c01ffa4a96 added brokers in producer to retrieve list of brokers from zookeeper, 
cool
 2013-06-07 16:35:48 +01:00
Paul Ingles
590f303a49 fix reflection warning 2013-06-07 16:30:16 +01:00
Paul Ingles
391f790cde remove reflection warning in producer code 2013-06-07 16:27:08 +01:00
Paul Ingles
cfa6b0854f remove some reflection warnings from the zookeeper consumer code 2013-06-07 16:24:33 +01:00
Paul Ingles
9945751c2f remove example; will replace in README later 2013-06-07 16:20:20 +01:00
Paul Ingles
989965a2d1 add example for simple consumer 2013-06-07 14:57:41 +01:00