Matias Fontanini
4b25f928a1
Merge pull request #194 from accelerated/master
...
Fixed pkg_config file
2019-05-17 11:25:12 -07:00
Alexander Damian
6adf1e82c9
Fixed pkg_config file template by adding boost dependency and correcting rdkafka library name
2019-05-17 14:19:28 -04:00
Matias Fontanini
bb0beb6db6
Define constructor for new exception
...
Fixes #193
2019-05-17 09:14:35 -07:00
Matias Fontanini
bbc3af67d9
Merge pull request #189 from accelerated/fix_versioning
...
Fixed version macros
2019-05-16 09:21:23 -07:00
Matias Fontanini
a0530d79a9
Merge pull request #190 from accelerated/pc_config
...
Support for generating pkg-config file
2019-05-16 09:19:03 -07:00
Alexander Damian
d148fe18d5
Added config option for PKGCONFIG install location
2019-05-15 13:44:07 -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
24e94fbfbc
Added boost include dirs to pkg config file
2019-05-08 10:28:49 -04:00
Matias Fontanini
b91350d6a4
Merge pull request #187 from accelerated/master
...
Added commit termination callback functionality in BackoffComitter
2019-05-02 08:36:17 -07:00
Alexander Damian
bd43d3c767
Support for generating pkg-config file
2019-04-26 16:19:54 -04:00
Alexander Damian
40d0221052
Fixed version macros
2019-04-26 14:36:03 -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
d84b75ca9d
Merge branch 'master' of https://github.com/mfontanini/cppkafka
2019-04-24 10:52:53 -04:00
Alexander Damian
0c1119727b
Replaced termination callback with throwing exception
2019-04-24 10:40:29 -04:00
proller
e8c4397b66
Fix build on some libcxx implementations ( #175 )
2019-04-24 09:16:14 -04:00
accelerated
470a5b6857
Set CMAKE_CXX_FLAGS only when not set
2019-04-24 09:16:14 -04:00
proller
df4eaa0735
Fix build on some libcxx implementations ( #175 )
2019-03-07 10:13:15 -08:00
Matias Fontanini
de85a329cb
Merge pull request #174 from accelerated/cxxflags
...
Set CMAKE_CXX_FLAGS only when not set
2019-03-04 20:19:57 -08:00
Matias Fontanini
a17a6f3b55
Merge pull request #172 from snar/freebsd-fix
...
Fix FreeBSD builds
2019-03-04 20:19:09 -08:00
accelerated
a935d1cb2e
Set CMAKE_CXX_FLAGS only when not set
2019-03-02 18:51:25 -05:00
Alexandre Snarskii
ca729ef6f0
Fix FreeBSD builds
2019-03-01 13:47:40 +03:00
Matias Fontanini
c9c46d7a1f
Merge pull request #171 from accelerated/async_flush
...
Added wait_for_acks(0) when calling async_flush
2019-02-23 11:27:13 -08: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
Matias Fontanini
4a887607b3
Merge pull request #164 from accelerated/offset_store
...
Added consumer legacy offset store API
2019-02-07 09:00:17 -08:00
accelerated
9bf535ac49
Simplify round-robin test due to intermittent errors
2019-02-06 22:45:12 -05:00
accelerated
8ae5e9d573
Fixed buffer test array initialization warning for clang
2019-02-06 18:47:36 -05: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
Matias Fontanini
872ee0442b
Merge pull request #163 from accelerated/status_version_fix
...
Fix message status version
2019-01-31 09:03:40 -08:00
accelerated
63327461bd
Fix message status version
2019-01-31 09:29:48 -05:00
Matias Fontanini
efa4e95a18
Merge pull request #157 from demin80/buffer-size-comparison-fix2
...
added type conversion to avoid signed-vs-unsigned-comparison warning
2019-01-19 08:12:55 -08:00
demin80
755e9f10c2
added missing return
2019-01-18 16:58:03 -05:00
Matias Fontanini
fb4c5edc8e
Merge pull request #159 from accelerated/check_error_fix
...
Fix error check in partition list
2019-01-16 12:27:57 -08:00
accelerated
dc732445f7
Fixes #158
2019-01-16 15:09:27 -05:00
demin80
5a34955fae
added type conversion to avoid signed-vs-unsigned-comparison warning
2019-01-16 10:52:14 -05:00
Matias Fontanini
05cc8304df
Merge pull request #153 from demin80/hi-priority-queue-fix
...
Added a high-priority queue to BufferedProducer to avoid message re-ordering
2019-01-14 20:08:47 -08:00
Matias Fontanini
2c6a47d68d
Merge pull request #156 from psigen/patch-1
...
Use CMAKE_STATIC_LIBRARY_* macros for FindRdKafka
2019-01-14 09:18:50 -08:00
Pras Velagapudi
85b7e579e2
Use CMAKE_STATIC_LIBRARY_* macros for FindRdKafka
...
In the current implementation, library suffixes are hard coded from a hand-maintained list. Instead of writing this list, we can use the CMake macros for platform specific library prefix/suffixes.
E.g. https://cmake.org/cmake/help/v3.0/variable/CMAKE_STATIC_LIBRARY_SUFFIX.html
This also resolves library resolution on Mac OSX, which does not currently work on the native `.dylib` suffix for shared libraries.
2019-01-12 15:51:11 -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
Matias Fontanini
4ba6b38b6e
Merge pull request #149 from accelerated/queue_full
...
Added queue full notification
2019-01-06 16:52:12 -08: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
