Telecominfraproject/wlan-cloud-lib-cppkafka
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-cloud-lib-cppkafka.git synced 2026-01-27 10:22:42 +00:00
Code Issues Packages Projects Releases Wiki Activity
147 Commits 1 Branch 3 Tags
04d5b41c6bfebb0a27513ae657869ac0ef8abc01
Commit Graph

147 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
Matias Fontanini
04d5b41c6b Add a project description to README.md 2017-08-28 21:29:35 -07:00
Matias Fontanini
c3011c9eed Remove redundant line in README.md 2017-08-28 21:24:20 -07:00
Matias Fontanini
d0c794b978 Increase expected acks on buffered producer after producing 2017-08-24 15:04:54 -07:00
Matias Fontanini
86d4bc8037 Make BasicConsumerDispatcher::Pauser a template type 2017-08-21 14:47:06 -07:00
Matias Fontanini
0d4b9ef2f6 Don't keep looping on NO_OFFSET error on backoff committer 2017-08-03 09:33:09 -07:00
Matias Fontanini
1582f6156d Allow consuming message batches 
Fixes #3
 2017-07-17 19:17:57 -07:00
Matias Fontanini
2340046544 Clear messages acked/expected acks on buffered producer 2017-07-11 10:17:58 -07:00
Matias Fontanini
b7a0dce710 Add a generic "event" event on ConsumerDispatcher 2017-07-04 18:23:42 -07:00
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