Alexander Damian
|
d20cab69f3
|
Add CMake configuration file and export installed targets
|
2019-06-29 01:50:29 -04:00 |
|
Alexander Damian
|
6499ef9869
|
Merge branch 'master' of https://github.com/mfontanini/cppkafka into pc_config
|
2019-05-10 16:10:37 -04:00 |
|
Alexander Damian
|
bd43d3c767
|
Support for generating pkg-config file
|
2019-04-26 16:19:54 -04:00 |
|
Alexander Damian
|
6e076810a0
|
Added ActionTerminatedException to BackoffPerformer
|
2019-04-26 11:12:52 -04:00 |
|
Alexander Damian
|
81a131ff16
|
Return true when RD_KAFKA_RESP_ERR__NO_OFFSET is received
|
2019-04-24 17:39:59 -04:00 |
|
Alexander Damian
|
effdf7fb95
|
Removed ReturnType. Throw on error from inside do_commit() as well as from perform()
|
2019-04-24 16:42:56 -04:00 |
|
Alexander Damian
|
0c1119727b
|
Replaced termination callback with throwing exception
|
2019-04-24 10:40:29 -04:00 |
|
Alexandre Snarskii
|
ca729ef6f0
|
Fix FreeBSD builds
|
2019-03-01 13:47:40 +03:00 |
|
accelerated
|
ace18d5d7b
|
Added wait_for_acks(0) when calling async_flush
|
2019-02-21 15:21:16 -05:00 |
|
Pavel Pimenov
|
5bfc047263
|
Fix detected by PVS-Studio (#167)
* Fix PVS-Studio
V591 Non-void function should return a value.
V519 The 'new_item' variable is assigned values twice successively.
|
2019-02-20 18:30:48 -08:00 |
|
accelerated
|
e19d84b839
|
Added compile time check for store_offsets() api
|
2019-02-06 17:47:02 -05:00 |
|
accelerated
|
4f4c9e9c91
|
Changes per code review
|
2019-02-06 13:01:57 -05:00 |
|
accelerated
|
284e1c57a9
|
Changed store_offsets() to use the actual position from the assignment
|
2019-02-04 14:23:59 -05:00 |
|
accelerated
|
7bc03185a8
|
Added legacy offset store API
|
2019-02-04 12:26:04 -05:00 |
|
accelerated
|
63327461bd
|
Fix message status version
|
2019-01-31 09:29:48 -05:00 |
|
demin80
|
755e9f10c2
|
added missing return
|
2019-01-18 16:58:03 -05:00 |
|
demin80
|
5a34955fae
|
added type conversion to avoid signed-vs-unsigned-comparison warning
|
2019-01-16 10:52:14 -05:00 |
|
demin80
|
93c2edf6ba
|
refactored by adding retry_mutex_ and replacing bools with enums; fixed formatting issues
|
2019-01-10 14:37:46 -05:00 |
|
demin80
|
71c4e02143
|
Revised the implementation based on the reviewers' response
|
2019-01-08 13:48:26 -05:00 |
|
demin80
|
00370c981d
|
Fixed spacing issues
|
2019-01-07 14:42:32 -05:00 |
|
demin80
|
97229ebfd9
|
Added a high-priority queue to BufferedProducer to avoid message re-ordering
|
2019-01-07 14:39:09 -05:00 |
|
accelerated
|
4a6b6779ad
|
Updated callback description
|
2019-01-06 17:40:39 -05:00 |
|
accelerated
|
97d1bb9434
|
Added queue full notify callback
|
2019-01-06 17:35:55 -05:00 |
|
accelerated
|
ed81ce446d
|
Added queue full notification
|
2019-01-06 16:59:00 -05:00 |
|
Matias Fontanini
|
520465510e
|
Revert "Add support for Buffer construction via raw arrays"
This reverts commit 74acf65fa6.
|
2018-12-17 09:18:28 -08:00 |
|
Matias Fontanini
|
40ee64c5c1
|
Merge pull request #140 from tgaldes/master
Add support for Buffer construction via raw arrays
|
2018-12-16 11:42:29 -08:00 |
|
Matias Fontanini
|
f14a4b9e8c
|
Merge pull request #150 from accelerated/flush_bug
Bug with message leak in BufferedProducer::flush(timeout)
|
2018-12-16 09:45:35 -08:00 |
|
accelerated
|
8b431c5421
|
changed rbegin to begin
|
2018-12-14 16:33:20 -05:00 |
|
accelerated
|
4a24971d3f
|
Fixed bug with message leak in BufferedProducer::flush(timeout)
|
2018-12-14 16:08:57 -05:00 |
|
accelerated
|
8dd5428c49
|
Added similar logic for ProduceTerminationCallback
|
2018-12-13 15:04:12 -05:00 |
|
accelerated
|
0b9b7bab11
|
Added flush termination callback
|
2018-12-13 10:43:29 -05:00 |
|
accelerated
|
06ddd79a29
|
Support for raw array Buffer constructor
|
2018-12-10 15:42:04 -05:00 |
|
accelerated
|
25c2eaa998
|
Changed iterator logic to capture header list by reference
|
2018-12-06 10:37:02 -05:00 |
|
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
|
6bbddcd5d5
|
Fixed Message::set_header_list as per review comments. Changed ClonablePtr to use clone() internally
|
2018-12-03 09:48:32 -05:00 |
|
accelerated
|
e96dc6d1fc
|
Added comments
|
2018-12-02 15:00:07 -05:00 |
|
accelerated
|
0b7931bfb8
|
Added Buffer::Buffer(iter, iter) constructor overload
|
2018-12-02 14:42:02 -05:00 |
|
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 |
|
Farnaz Jahanbakhsh
|
d06cd222fe
|
include <array>
|
2018-11-26 00:26:04 +00:00 |
|
Tyler Galdes
|
74acf65fa6
|
Add support for Buffer construction via raw arrays
|
2018-11-19 19:59:08 -05: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 |
|
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 |
|