accelerated
1c80af9b68
Added constructor from another HeaderList type
2018-12-05 20:04:10 -05:00
accelerated
fe0c7e7dd5
Fixed end() iterator and also applied default copy-constructor instead of passing null handle in BasicMessageBuilder
2018-12-05 12:15:25 -05:00
accelerated
93e066a1c1
* Added asserts when building a HeaderList and removed checks for handle
...
validity.
* Removed explicit move semantic when cloning a MessageBuilder.
* Renamed clone() to try_clone() in ClonablePtr class.
2018-12-04 11:12:28 -05:00
accelerated
c7ba478582
Header fixes
2018-11-30 09:55:26 -05: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
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
accelerated
a4eefacaa1
concurrency issues in MessageBuilder internal data
2018-06-10 18:48:51 -04:00
accelerated
71e6e2e4e5
added retry logic for producers
2018-06-10 13:00:55 -04:00
Alex Damian
429ec92369
Buffered producer thread safe ( #72 )
...
* Thread safe buffered producer
* Using single mutex version
* Changed based on feedback
* Changes based on latest review
* Added flush counter
2018-05-28 18:33:36 -07:00
Matias Fontanini
df12b5fd5c
Fix linking issues on Windows
...
Relates to #10
2018-03-20 08:12:04 -07:00
Matias Fontanini
9594ddced3
Update license
2017-05-06 08:27:47 -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
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
c99c8bbb05
Add CPPKAFKA_API macro to MessageBuilder declaration
2017-04-15 17:25:31 -07:00
Matias Fontanini
e26d7e7db2
Add MessageBuilder and use it on producer classes
2017-04-15 16:46:37 -07:00
