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 |
|
Paul Ingles
|
f84c7dcc83
|
remove unused fns
|
2013-06-07 14:20:24 +01:00 |
|
Paul Ingles
|
c44ddf8dba
|
rename test
|
2013-06-07 14:19:41 +01:00 |
|
Paul Ingles
|
4c10bf6c48
|
both tests are the same
|
2013-06-07 14:18:46 +01:00 |
|
Paul Ingles
|
9f23aec1df
|
fix cleanup after test run; add MessagePayload protocol and second test
|
2013-06-07 14:17:38 +01:00 |
|
Paul Ingles
|
fa0de3cae0
|
update code to pass test; consumes messages but clj-kafka.consumer.zk/messages can't map the contents for us...
|
2013-06-07 13:55:17 +01:00 |
|
Paul Ingles
|
f4a1ebe88a
|
more work on updating for 0.8 api; clj-kafka.test.consumer is WIP and hangs currently when creating the messages sequence
|
2013-06-07 13:03:55 +01:00 |
|
Paul Ingles
|
2492aee358
|
Revert "work on updating the api to work against 0.8"
This reverts commit 5286bbfbb6 .
|
2013-06-07 10:48:08 +01:00 |
|
Paul Ingles
|
5286bbfbb6
|
work on updating the api to work against 0.8
|
2013-06-07 10:23:13 +01:00 |
|
Paul Ingles
|
f3d01cbfba
|
remove println
|
2013-06-07 09:43:14 +01:00 |
|