Tyler Galdes
757d2b623f
Add support for constructing Buffer from std::array
2018-11-16 19:49:52 -05:00
accelerated
70aef6681d
Added API description for Message::get_status
2018-11-12 12:14:20 -05:00
accelerated
9859e54522
Added support for message status and setting the event mask
2018-11-12 10:30:54 -05: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
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
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
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
Zenon Parker
d3ef9cad32
Fix #111 : Rename LogLevel enums ( #112 )
2018-08-30 11:28:12 -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
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
c5aca985b8
Invoke error callback if present instead of log callback ( #93 )
2018-06-20 09:11:24 -07:00
Alex Damian
eb46b8808e
Bug fixes for sync flush and add_tracker ( #91 )
...
* fixes for sync flush and also add_tracker
* added flag for flush
2018-06-18 14:46:31 -07:00
Alex Damian
b8f4be5e1b
Increase buffer construction requirements ( #88 )
...
* Fix crash in Buffer with null pointer and non-zero length
* Throw inside Buffer constructor instead
2018-06-18 09:09:48 -07:00
accelerated
3c72eb5752
Added timeout to flush and wait_for_acks
2018-06-14 11:43:12 -04:00
accelerated
f220062e40
Changed purge to async_flush
2018-06-12 10:23:48 -04:00
accelerated
7530b9f9e4
added method to empty the buffer when max limit is reached
2018-06-12 09:21:55 -04:00
accelerated
3cf9bb53e9
Added purge (aka async_flush) functionality
2018-06-12 09:17:41 -04:00
accelerated
972a008aa4
Changed test to produce twice the same MessageBuilder
2018-06-11 15:45:41 -04:00
accelerated
a4eefacaa1
concurrency issues in MessageBuilder internal data
2018-06-10 18:48:51 -04:00
accelerated
23810654ab
Removed dependency on Producer and dr_callback_proxy
2018-06-10 13:00:56 -04:00
accelerated
f746653841
Added logic to conditionally enable internal data
2018-06-10 13:00:56 -04:00
accelerated
71e6e2e4e5
added retry logic for producers
2018-06-10 13:00:55 -04:00
Matias Fontanini
f15b59cb13
Fix compacted topic processor test
...
* Use buffered producer on compacted topic processor test
* Add include directives for callback invoker where missing
* Consume until EOF on compacted topic processor test
2018-06-09 14:49:50 -07:00
sachnk
5dcede6411
#81 : add detail headers to installation ( #82 )
2018-06-09 10:32:10 -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
Alex Damian
9714bec5bf
Callback invoker to sink all thrown exceptions ( #74 )
2018-06-01 16:35:56 -07:00
accelerated
ea9601ba1b
Changes per code review
2018-05-29 10:05:56 -04:00
accelerated
ffc64b9a5a
Remove valgrind warning
2018-05-29 10:05:56 -04:00
accelerated
556f15a43f
Allow access to the user-supplied delivery callback.
2018-05-29 09:59:19 -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
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
