scottk/wlan-cloud-lib-cppkafka
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-cloud-lib-cppkafka.git synced 2025-11-01 19:18:04 +00:00
Code Issues Packages Projects Releases Wiki Activity
277 Commits 1 Branch 3 Tags
57bddabfd0f062c74da49ad69cd3e8b0be2aae46
Commit Graph

277 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
accelerated
57bddabfd0 Removed clone_handle method and made ClonablePtr::clone private 2018-12-02 14:15:20 -05:00
accelerated
c7ba478582 Header fixes 2018-11-30 09:55:26 -05:00
Matias Fontanini
5aa4bc08a3 Fix kafka download URL in travis file 2018-11-26 19:47:58 -08:00
Matias Fontanini
5a4481dc28 Merge pull request #142 from farnazj/master 
Add <array> header
 2018-11-26 19:06:45 -08:00
Farnaz Jahanbakhsh
d06cd222fe include <array> 2018-11-26 00:26:04 +00:00
Matias Fontanini
4ad2685d61 Merge pull request #138 from tgaldes/master 
Add support for constructing Buffer from std::array
 2018-11-19 16:58:34 -08:00
Tyler Galdes
248d1b0638 Delete construction of buffer with rvalue arrays 2018-11-19 19:48:02 -05:00
Tyler Galdes
b48036fe62 use std::array functions for pointer and size of data 2018-11-19 11:49:17 -05:00
Tyler Galdes
757d2b623f Add support for constructing Buffer from std::array 2018-11-16 19:49:52 -05:00
Matias Fontanini
4b7a10ec90 Merge pull request #136 from accelerated/master 
Remove setting log level in the constructor
 2018-11-13 14:50:15 -08:00
accelerated
b366cf4bf6 Remove setting log level in the constructor 2018-11-13 15:28:06 -05:00
Matias Fontanini
7b4c3e163f Merge pull request #135 from accelerated/events 
Added API description for Message::get_status
 2018-11-12 10:26:30 -08:00
accelerated
70aef6681d Added API description for Message::get_status 2018-11-12 12:14:20 -05:00
Matias Fontanini
29cb02b756 Merge pull request #134 from accelerated/events 
Added support for message status and setting the event mask
 2018-11-12 09:05:27 -08:00
accelerated
9859e54522 Added support for message status and setting the event mask 2018-11-12 10:30:54 -05:00
Matias Fontanini
9f6556da0c Merge pull request #125 from mfontanini/events 
Event implementation
 2018-11-10 10:43:05 -08:00
Matias Fontanini
46481d879f Use BufferedProducer in round robin consumer test 
Hopefully this will get rid of the sporadic failures
 2018-11-10 10:26:03 -08:00
Matias Fontanini
25e3aacf4a Add compile guard for rd_kafka_event_stats 2018-11-10 10:26:03 -08:00
Matias Fontanini
1f1f1c253b Fix build issue when using rd_kafka_message_latency in old rdkafka 2018-11-10 10:26:03 -08:00
Matias Fontanini
24960c0a49 Build library on travis using rdkafka 0.9.4 as well 2018-11-10 10:26:03 -08:00
Matias Fontanini
4ac837d831 Disable even consumption test 2018-11-10 10:26:03 -08:00
Matias Fontanini
b242e2c35c Allow setting background event callback on configuration handles 2018-11-10 10:26:03 -08:00
Matias Fontanini
19baa03cea Allow getting background queue out of kafka handle base 2018-11-10 10:26:03 -08:00
Matias Fontanini
8dc94869fd Move get_queue behavior into Queue class 2018-11-10 10:25:31 -08:00
Matias Fontanini
71fb76b8e1 Add dumb test that extracts event from queue 2018-11-10 10:25:31 -08:00
Matias Fontanini
c7e1dcb60a Allow checking if an Event is valid 2018-11-10 10:25:31 -08:00
Matias Fontanini
e73c997a0c Allow getting Events out of Queues 2018-11-10 10:25:31 -08:00
Matias Fontanini
b46991db7e Add Event class 2018-11-10 10:25:31 -08:00
Alex Damian
b0ddceda1f Message timestamp refactoring and log level changes (#133) 
* Message timestamp refactoring and log level changes

* Changes per code review
 2018-11-07 08:36:57 -08:00
Matias Fontanini
451d60295a Remove MessageTimestamp constructor from time_point (#129) 2018-10-26 18:57:28 -07:00
Alex Damian
57268e666c Added time_point overloads for creating timestamps. (#128) 
* Added time_point overloads for creating timestamps.

* aliased std::chrono types
 2018-10-25 07:39:22 -07:00
Alex Damian
ad9a1e4a49 If timeout is 0, the function should at least run once (#123) 2018-10-22 07:55:29 -07:00
Matias Fontanini
416a7d43ce Minor documentation fixes 2018-10-21 10:17:10 -07:00
Matias Fontanini
a2d17a6f45 Test suite fixes (#124) 
* Move polling strategy adapter definition into test_utils.cpp

* Use a random consumer group id in every test
 2018-10-20 20:32:32 -07:00
Matias Fontanini
0d54acbc64 Flush producer in example 2018-10-19 08:42:10 -07:00
Matias Fontanini
b2ba4cbfa3 Add comment regarding flushing producer 2018-10-19 08:41:36 -07:00
multiprogramm
2b66fd3a22 Fix windows linker errors (#120) 2018-10-17 10:43:33 -07:00
Alex Damian
fbe3759fed Header support implementation (#115) 
* header support implementation

* Fixed issue when ptr is null and doesn't have a cloner function

* Code complete with test cases

updated travis file with v0.11.5

* Added compile time check for rdkafka header support version

* Changes per last code review

* Using brace list initializers
 2018-10-16 10:58:05 -07:00
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
d77e7466b8 changed assert with if statement (#116) 2018-10-06 09:28:45 -07:00
Matias Fontanini
f458514fb2 Bump version to 0.2 0.2 2018-09-20 18:23:32 -07:00
Zenon Parker
d3ef9cad32 Fix #111: Rename LogLevel enums (#112) 2018-08-30 11:28:12 -07:00
shashank khare
df04b27e22 Fix #104: memory leak in poll_batch (#107) 
poll_batch currently leaks memory while initialising the queue
returned by rd_kafka_queue_get_consumer. The fix as suggested
by @mfontanini as done here is to initialise the queue with a
Queue so it's cleaned up when going out of scope.
 2018-07-26 08:56:42 -07:00
Alex Damian
d6f8129207 Fix for ref count on queue handles (#92) 
* Fix for ref count on queue handles

* added check for rdkafka version

* changed to runtime version checking
 2018-07-23 17:07:35 -07:00
Sergey Batanov
3238c94f43 Fix #83: define LIBRDKAFKA_STATICLIB (#99) 
* Fix #83: define LIBRDKAFKA_STATICLIB

* Moved LIBRDKAFKA_STATICLIB definition
 2018-07-04 08:26:25 -07:00
Sergey Batanov
081f8d80a0 Fix #97: struct switched to class. (#98) 
To avoid name mangling difference in MSVC.
 2018-07-02 16:57:52 -07:00
Alex Damian
577bbb0242 added error check for partition list (#90) 2018-06-26 08:57:49 -07:00
Matias Fontanini
6158d932c0 Example fixes (#96) 
* Add example for kafka buffered producer

* Add notes regarding bool returned in produce failure callback

* Fix example names
 2018-06-25 19:19:23 -07:00
Alex Damian
5c72f3fe28 Added pause/resume for producers (#87) 
* Added pause/resume for producers

* Moved pause/resume functions to KafkaHandleBase
 2018-06-25 09:16:57 -07:00
Alex Damian
069ea3df8e Specific linking option for rdkafka library (#94) 2018-06-25 07:03:11 -07:00