17 Commits

Author	SHA1	Message	Date
Alex Damian	9af4330c6d	Allocators (#118) ... * Added allocator support for consumers and buffered producer * Changed MessageList back to std::vector<Message> for consistency with the allocator API	2018-10-16 08:57:11 -07:00
Alex Damian	5cad740aea	Added access to the internal Consumer in the backoff committer (#75) ... * Added access to the internal Consumer and provided non-default constructor for BackoffPerformer * added sync_produce and deleted the value constructor * removed sync_produce methods * removed value constructor in backoff_performer class	2018-06-04 11:48:20 -07:00
accelerated	ea9601ba1b	Changes per code review	2018-05-29 10:05:56 -04:00
accelerated	6144330835	added test case for polling strategy refactored the strategy class	2018-05-29 09:55:30 -04:00
accelerated	169ea4f8ed	Fixes to queue polling and making them non-owning	2018-05-29 09:55:30 -04:00
accelerated	532d83b225	Removed reserve() and synced consumer::poll_batch and queue::poll_batch functions	2018-05-29 09:55:30 -04:00
accelerated	a1ce130bfd	changes as per code review	2018-05-29 09:55:29 -04:00
accelerated	71afaba3e1	added support for different topics/partitions	2018-05-29 09:55:29 -04:00
accelerated	15be627f8e	intial polling version	2018-05-29 09:55:29 -04:00
Alex Damian	d9feb5c3db	Added retry limit for the backoff performer class (#70)	2018-05-23 09:16:12 -07:00
Matias Fontanini	5889c322c2	Fix link issues when building in clang	2017-10-02 10:31:02 -07:00
Matias Fontanini	9e6315fcc2	Make ConsumerDispatcher a template class	2017-07-04 18:07:22 -07:00
Matias Fontanini	556dac7015	Add backoff performer class	2017-06-16 19:27:18 -07:00
Matias Fontanini	52822fdb61	Move some small functions into header files	2017-06-10 19:15:53 -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	9c9d1e494d	Add BackoffCommitter class	2017-05-07 11:37:07 -07:00