yogsototh/clj-kafka
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Commit graph

  • f62b4f21c4 Merge pull request #43 from kelveden/master master Paul Ingles 2015-02-18 12:05:15 +0000
  • 1cae2a54fd Update URL references to kafka incubator to use the 'real' kafka. Alistair Dutton 2015-02-18 11:15:18 +0000
  • 61d07ef92f Merge pull request #40 from DayoOliyide/master Paul Ingles 2015-02-10 09:34:29 +0000
  • b5eca47aa8 Extend ToClojure protocol to nil Dayo Oliyide 2015-02-09 20:02:45 +0000
  • a776d070ae release 0.2.8-0.8.1.1, adds url and license for clojars promotion 0.2.8-0.8.1.1 Paul Ingles 2014-11-19 09:24:45 +0000
  • 18bacba342 add url and license for promotion in clojars Paul Ingles 2014-11-19 09:24:10 +0000
  • c6bb228222 bump release! thanks to @fatlazycat 0.2.7-0.8.1.1 Paul Ingles 2014-11-19 09:16:04 +0000
  • d2173cbe8e style tweak Paul Ingles 2014-11-19 09:15:29 +0000
  • 1a695580a4 Upgraded kafka to 0.8.1.1 and zkclient to 0.4 Graham Berks 2014-11-18 21:26:17 +0000
  • 678caa5b2c Merge pull request #36 from MastodonC/add-license-file Paul Ingles 2014-10-23 18:18:10 +0100
  • c9943ecb5f Add EPL License file. Neale Swinnerton 2014-10-23 17:57:38 +0100
  • 93a89f41bb Merge branch 'master' of github.com:pingles/clj-kafka Paul Ingles 2014-05-14 10:22:32 +0100
  • 345d8ba0ff add clj-kafka latest version badge to README Paul Ingles 2014-05-14 10:22:06 +0100
  • d8848eb275 Merge pull request #28 from l1x/master Paul Ingles 2014-05-14 10:18:21 +0100
  • 89dd4f95ae Updating README.md Istvan Szukacs 2014-05-13 11:19:21 -0700
  • c397a8ff1b release 0.2.6 Paul Ingles 2014-05-09 17:45:14 +0100
  • 3cf86987bb use create-all when creating the node Paul Ingles 2014-05-09 17:44:57 +0100
  • 031b80f05d bump clj-kafka release Paul Ingles 2014-05-09 11:58:48 +0100
  • 6b506b692e add committed-offset and set-offset! to allow offsets to be manipulated/read directly Paul Ingles 2014-05-09 11:57:41 +0100
  • 96275316e9 release with zookeeper partitions fn Paul Ingles 2014-05-07 17:50:10 +0100
  • 308c76a864 add partitions fn to access partition/replica data Paul Ingles 2014-05-07 17:49:06 +0100
  • ddb0a77391 add topic-offset to simple consumer: can be used to determine earliest offset available too Paul Ingles 2014-05-01 15:23:56 +0100
  • 5b7afa5723 add thanks to yourkit in README Paul Ingles 2014-04-30 10:01:42 +0100
  • 52032432b9 add number of consumer threads to zk consumer Paul Ingles 2014-04-28 14:12:41 +0100
  • 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. Paul Ingles 2014-04-15 13:54:29 +0100
  • 157ca25220 update version in README Paul Ingles 2014-04-15 13:25:35 +0100
  • f0c025d358 Merge pull request #25 from prepor/lazy-iterate Christian Blunden 2014-03-19 14:27:47 +0000
  • 4ff8334299 Do not use iterator-seq with KafkaStream prepor 2014-03-19 20:45:49 +0900
  • 9c19d5df43 Merge pull request #22 from uswitch/unqueued-zk-consumer Paul Ingles 2014-03-05 12:59:19 +0000
  • 9a42598d83 Up project version to reflect breaking change Russell 2014-02-24 12:38:03 +0000
  • 1723d57e81 Add nrepl-port to gitignore Russell 2014-02-24 12:35:52 +0000
  • ce5cd3eaa2 Remove no longer used pipe implementation Russell 2014-02-24 09:31:53 +0000
  • 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. Russell 2014-02-24 09:29:22 +0000
  • edda2420ae Merge pull request #21 from jpfuentes2/patch-1 Paul Ingles 2013-12-20 07:21:15 -0800
  • ac8ce7090c Fix producer example and lein version string Jacques Fuentes 2013-12-17 15:25:11 -0500
  • 8f2370e6b5 update README to reflect recent changes Paul Ingles 2013-12-15 21:01:28 +0000
  • 08611c67c6 release 0.1.2 built with kafka 0.8 final release 0.1.2-0.8 Paul Ingles 2013-12-15 20:56:40 +0000
  • 98a039115b update tests and fix controller fn to extract the controller brokerid Paul Ingles 2013-12-15 20:55:05 +0000
  • ea2992b83b updates for kafka 0.8 release; few changes in zk structures so needs more work Paul Ingles 2013-12-15 19:39:27 +0000
  • d61c4321a4 move metrics-core and zkclient into core dependencies- they're dependencies of kafka that aren't pulled automatically Paul Ingles 2013-11-18 13:41:52 +0000
  • 6684e30213 change release number in README Paul Ingles 2013-09-19 11:22:14 +0100
  • 62a3ed8ed9 Merge branch '0.8' Paul Ingles 2013-09-19 11:20:30 +0100
  • 422ccf2b84 update project to use Kafka's 0.8-beta1 release Paul Ingles 2013-09-19 11:15:01 +0100
  • 7173fd6b11 note 0.8 branch in main readme Paul Lam 2013-07-14 16:26:47 +0100
  • 9e8510d4c9 Merge pull request #17 from rwat/0.8 Paul Ingles 2013-06-13 01:11:59 -0700
  • ed0aa8b919 fixed typo rwat 2013-06-12 16:40:56 -0500
  • 52c61f12c1 await kafka shutdown to minimise errors reported in logs Paul Ingles 2013-06-10 20:13:53 +0100
  • f9a1e978ca map simple consumer messages to-clojure Paul Ingles 2013-06-10 15:22:59 +0100
  • f997dcfcb0 rename :zookeeper-connect in to-clojure to :connect - it is the details to connect directly to the broker Paul Ingles 2013-06-10 15:07:33 +0100
  • b543bdcb5a Merge branch '0.8' of github.com:pingles/clj-kafka into 0.8 Paul Lam 2013-06-10 13:54:23 +0100
  • e71246eda1 add latest-topic-offset to simple consumer Paul Lam 2013-06-10 13:54:09 +0100
  • fe273bf32c move expectations dependency into the dev profile Paul Ingles 2013-06-10 12:46:08 +0100
  • 6a547f5616 get topics from zk Paul Lam 2013-06-10 12:13:03 +0100
  • 27ba361517 zk/controller to get leader node Paul Lam 2013-06-10 11:56:49 +0100
  • c46c916ca0 zk ns to hold zookeeper methods Paul Lam 2013-06-10 11:36:37 +0100
  • 602be6f061 add :broker-id for to-clojure on Broker Paul Lam 2013-06-10 11:23:18 +0100
  • 7978821026 topic-meta-data pass in topic and returns brokers with that topic Paul Lam 2013-06-10 11:20:00 +0100
  • dd1cdeeb86 mv test ns consumer.clj into consumer/zk.clj Paul Lam 2013-06-10 10:47:18 +0100
  • 2f24376609 use zookeeper-port in tests Paul Lam 2013-06-10 09:23:00 +0100
  • 10c22c7d21 update the README following the 0.8 changes over the weekend Paul Ingles 2013-06-10 09:17:53 +0100
  • 4baa38f97d add some type hints to avoid reflection in some key fns Paul Ingles 2013-06-09 16:17:36 +0100
  • b9d3c7a069 update travis-ci to run only expectations Paul Ingles 2013-06-09 09:17:38 +0100
  • 6e19e4c8b3 fix travis-ci config to run lein2 command Paul Ingles 2013-06-09 08:41:57 +0100
  • d9ab7ba672 update travis-ci to run both tests and expectations; started rewriting tests as expectations Paul Ingles 2013-06-09 08:39:46 +0100
  • 1d92367158 deleting empty test ns Paul Ingles 2013-06-09 08:24:15 +0100
  • 5ba3d9b67b delete MessageValue protocol- clients should know whether they're providing a byte array or not and they can implement their own protocols. Paul Ingles 2013-06-09 08:17:48 +0100
  • 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. Paul Ingles 2013-06-09 08:15:03 +0100
  • b373042058 delete ToClojure extension for ByteBuffer: didn't make any sense given it just extracts the bytes Paul Ingles 2013-06-09 08:01:47 +0100
  • f75c4b339a change log4j to append to ./logs/kafka.log; tidy the zk consumer test Paul Ingles 2013-06-09 07:51:34 +0100
  • 257c25293d remove println; move test broker config into a Var Paul Ingles 2013-06-09 07:43:24 +0100
  • 76ede151a4 pull paren up Paul Ingles 2013-06-08 11:52:07 +0100
  • 1e014986c5 refactor test.utils/with-test-broker to receive config map specifying ports + topic name Paul Ingles 2013-06-08 11:49:52 +0100
  • be2cd0329f add queue-capacity option for zookeeper messages: can be used to limit LinkedBlockingQueue queue size with large messages Paul Ingles 2013-06-07 22:11:42 +0100
  • 84c813ae48 add message piping back; to-clojure conversion to KafkaMessage added by default Paul Ingles 2013-06-07 22:03:11 +0100
  • 57a9f17dfa rename with-broker to with-test-broker Paul Ingles 2013-06-07 21:55:11 +0100
  • ec1fb0671c rename MessagePayload to MessageValue Paul Ingles 2013-06-07 21:10:37 +0100
  • 6437dcd18d delete unused to-clojure definition Paul Ingles 2013-06-07 21:09:02 +0100
  • 8643566f5c add log4j properties to reduce logging in dev/test; delete tmp directory before test run too Paul Ingles 2013-06-07 20:58:23 +0100
  • cd525fa6bd fix hanging param from merge Paul Lam 2013-06-07 16:36:42 +0100
  • 20683d7e18 type hint consumer.simple Paul Lam 2013-06-07 16:34:15 +0100
  • c01ffa4a96 added brokers in producer to retrieve list of brokers from zookeeper, cool Paul Lam 2013-06-07 16:15:54 +0100
  • 590f303a49 fix reflection warning Paul Ingles 2013-06-07 16:30:16 +0100
  • 391f790cde remove reflection warning in producer code Paul Ingles 2013-06-07 16:27:08 +0100
  • cfa6b0854f remove some reflection warnings from the zookeeper consumer code Paul Ingles 2013-06-07 16:24:33 +0100
  • 9945751c2f remove example; will replace in README later Paul Ingles 2013-06-07 16:20:20 +0100
  • 989965a2d1 add example for simple consumer Paul Ingles 2013-06-07 14:57:41 +0100
  • f84c7dcc83 remove unused fns Paul Ingles 2013-06-07 14:20:24 +0100
  • c44ddf8dba rename test Paul Ingles 2013-06-07 14:19:41 +0100
  • 4c10bf6c48 both tests are the same Paul Ingles 2013-06-07 14:18:46 +0100
  • 9f23aec1df fix cleanup after test run; add MessagePayload protocol and second test Paul Ingles 2013-06-07 14:17:38 +0100
  • fa0de3cae0 update code to pass test; consumes messages but clj-kafka.consumer.zk/messages can't map the contents for us... Paul Ingles 2013-06-07 13:55:17 +0100
  • f4a1ebe88a more work on updating for 0.8 api; clj-kafka.test.consumer is WIP and hangs currently when creating the messages sequence Paul Ingles 2013-06-07 13:03:55 +0100
  • 2492aee358 Revert "work on updating the api to work against 0.8" Paul Ingles 2013-06-07 10:48:08 +0100
  • 5286bbfbb6 work on updating the api to work against 0.8 Paul Ingles 2013-06-07 10:23:13 +0100
  • f3d01cbfba remove println Paul Ingles 2013-06-07 09:43:14 +0100
  • 72cec16cd6 move with-broker testing stuff into test.utils ns Paul Ingles 2013-06-07 09:42:04 +0100
  • a89a454d3b create embedded zookeeper server Paul Ingles 2013-06-07 09:22:55 +0100
  • 79544297fe clean the kafka log directory before using the broker in tests Paul Ingles 2013-06-07 09:01:38 +0100
  • 72f8daed9e add system-time to implement Time interface for testing Paul Ingles 2013-06-07 08:53:01 +0100
  • f661446647 start work on adding some tests; update message tests for 0.8 api Paul Ingles 2013-06-07 08:33:51 +0100