139 Commits

This Branch

This Branch

All Branches

Author	SHA1	Message	Date
Matias Fontanini	08815e97c0	Add CPPKAFKA_API to utils classes	2017-07-04 18:09:06 -07:00
Matias Fontanini	9e6315fcc2	Make ConsumerDispatcher a template class	2017-07-04 18:07:22 -07:00
Matias Fontanini	191956b4ca	Pause/resume consumption on throttle	2017-06-17 09:39:50 -07:00
Matias Fontanini	4af48ff0e7	Allow throttling on ConsumerDispatcher	2017-06-17 08:52:48 -07:00
Matias Fontanini	556dac7015	Add backoff performer class	2017-06-16 19:27:18 -07:00
Matias Fontanini	4cd03aea3c	Cleanup ConsumerDispatcher code	2017-06-11 14:35:33 -07:00
Matias Fontanini	2e6bfd64d3	Fix comment typo	2017-06-10 19:37:48 -07:00
Matias Fontanini	ed71ab2daa	Add example using ConsumerDispatcher	2017-06-10 19:26:42 -07:00
Matias Fontanini	52822fdb61	Move some small functions into header files	2017-06-10 19:15:53 -07:00
Matias Fontanini	bb5fb490ce	Check if all callbacks match a signature on ConsumerDispatcher	2017-06-10 17:55:17 -07:00
Matias Fontanini	4369b75695	Use tags on EOF and timeout callbacks on ConsumerDispatcher	2017-06-10 17:39:23 -07:00
Matias Fontanini	f0ec0bfb10	Add ConsumerDispatcher class	2017-06-10 15:25:28 -07:00
Matias Fontanini	67022dbb68	Add notes about static building on README.md v0.1	2017-06-05 19:41:46 -07:00
Matias Fontanini	d458e4d668	Add uninstall target	2017-06-05 19:38:34 -07:00
Matias Fontanini	b79a1ae6da	Move endianness.h file into detail folder	2017-06-05 19:36:22 -07:00
Matias Fontanini	000a119daf	Add short options to kafka producer example	2017-06-05 19:30:51 -07:00
Matias Fontanini	e741f40fbb	Allow showing the member assignment in consumers info example	2017-06-05 19:29:11 -07:00
Matias Fontanini	67cad942ca	Add consumer groups information example	2017-06-04 11:31:40 -07:00
Matias Fontanini	7d3b33d9cb	Cleanup metadata example	2017-06-04 11:27:55 -07:00
Matias Fontanini	45c73a1f0c	Use Producer rather than Consumer in metadata example	2017-06-04 11:20:40 -07:00
Matias Fontanini	56d594d232	Add metadata fetching example	2017-06-04 11:10:27 -07:00
Matias Fontanini	acbae757d8	Remove all references to Partition class	2017-06-04 10:57:28 -07:00
Matias Fontanini	895a983d17	Allow constructing Buffers from std::vector	2017-06-04 08:32:19 -07:00
Matias Fontanini	c58a4792d3	Update README.md	2017-06-03 12:45:11 -07:00
Matias Fontanini	d88e2d9ed4	Fix build issue on Windows	2017-06-03 12:38:54 -07:00
Matias Fontanini	2f9170e32a	Fix build errors/warnings on Windows	2017-06-03 12:23:06 -07:00
Matias Fontanini	b5225926b4	Make FindRdKafka.cmake work on Windows	2017-06-03 12:06:41 -07:00
Matias Fontanini	9c9d1e494d	Add BackoffCommitter class	2017-05-07 11:37:07 -07:00
Matias Fontanini	9594ddced3	Update license	2017-05-06 08:27:47 -07:00
Matias Fontanini	bb900f21cb	Allow clearing buffered messages on buffered producer	2017-04-24 20:08:26 -07:00
Matias Fontanini	5e84da2458	Change logic to reset messages acked count on buffered producer	2017-04-23 14:55:33 -07:00
Matias Fontanini	7ec3252a86	Minor documentation improvements	2017-04-23 14:24:06 -07:00
Matias Fontanini	03189b82a1	Minor fixes on examples	2017-04-23 14:21:49 -07:00
Matias Fontanini	b5a7c70993	Expand description of BufferedProducer	2017-04-23 14:12:00 -07:00
Matias Fontanini	aab182c4ea	Allow producing messages without buffering them in buffered producer	2017-04-23 11:23:37 -07:00
Matias Fontanini	35cf6fd0bf	Catch flush timeout exception on buffered producer	2017-04-23 11:06:49 -07:00
Matias Fontanini	e7db3df966	Change internals of BufferedProducer	2017-04-23 11:01:21 -07:00
Matias Fontanini	dbb547889b	Allow getting consumer group information	2017-04-16 19:45:03 -07:00
Matias Fontanini	ebde747e18	Multiple fixes on README.md	2017-04-16 15:41:08 -07:00
Matias Fontanini	6e248e2bb5	Update list of requirements in README	2017-04-16 15:34:07 -07:00
Matias Fontanini	88dd16e0e7	Update code on README.md	2017-04-16 15:33:38 -07:00
Matias Fontanini	69b0f2166b	Update minimum librdkafka required version	2017-04-16 15:23:05 -07:00
Matias Fontanini	6c47b1a190	Allow setting timestamp on produced messages	2017-04-16 15:22:17 -07:00
Matias Fontanini	9ecad71be1	Remove Partition class	2017-04-16 14:51:06 -07:00
Matias Fontanini	f5c8c7c3c8	Require rdkafka v0.9.4 to build	2017-04-16 10:29:15 -07:00
Matias Fontanini	f924eb68e7	Allow making no key/payload copies in BufferedProducer	2017-04-16 10:14:12 -07:00
Matias Fontanini	f781afe5cf	Allow using generic message builders not tied to Buffer class	2017-04-16 10:14:12 -07:00
Matias Fontanini	861e41a792	Add note about the API being unstable	2017-04-15 19:25:40 -07:00
Matias Fontanini	8143c5b06a	Add KafkaHandleBase::get_offsets_for_times	2017-04-15 19:21:51 -07:00
Matias Fontanini	c9f3b0c5bc	Use std::chrono::milliseconds for message timestamp	2017-04-15 18:14:36 -07:00