scottk/wlan-cloud-lib-cppkafka
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-cloud-lib-cppkafka.git synced 2025-10-31 18:47:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

Commit Graph

  • effdf7fb95 Removed ReturnType. Throw on error from inside do_commit() as well as from perform() Alexander Damian 2019-04-24 16:42:56 -04:00
  • d84b75ca9d Merge branch 'master' of https://github.com/mfontanini/cppkafka Alexander Damian 2019-04-24 10:52:53 -04:00
  • 0c1119727b Replaced termination callback with throwing exception Alexander Damian 2019-04-24 10:30:32 -04:00
  • e8c4397b66 Fix build on some libcxx implementations (#175) proller 2019-03-07 21:13:15 +03:00
  • 470a5b6857 Set CMAKE_CXX_FLAGS only when not set accelerated 2019-03-02 18:51:25 -05:00
  • df4eaa0735 Fix build on some libcxx implementations (#175) proller 2019-03-07 21:13:15 +03:00
  • de85a329cb Merge pull request #174 from accelerated/cxxflags Matias Fontanini 2019-03-04 20:19:57 -08:00
  • a17a6f3b55 Merge pull request #172 from snar/freebsd-fix Matias Fontanini 2019-03-04 20:19:09 -08:00
  • a935d1cb2e Set CMAKE_CXX_FLAGS only when not set accelerated 2019-03-02 18:51:25 -05:00
  • ca729ef6f0 Fix FreeBSD builds Alexandre Snarskii 2019-03-01 13:47:40 +03:00
  • c9c46d7a1f Merge pull request #171 from accelerated/async_flush Matias Fontanini 2019-02-23 11:27:13 -08:00
  • ace18d5d7b Added wait_for_acks(0) when calling async_flush accelerated 2019-02-21 15:21:16 -05:00
  • 5bfc047263 Fix detected by PVS-Studio (#167) Pavel Pimenov 2019-02-21 05:30:48 +03:00
  • 4a887607b3 Merge pull request #164 from accelerated/offset_store Matias Fontanini 2019-02-07 09:00:17 -08:00
  • 9bf535ac49 Simplify round-robin test due to intermittent errors accelerated 2019-02-06 22:40:07 -05:00
  • 8ae5e9d573 Fixed buffer test array initialization warning for clang accelerated 2019-02-06 18:06:32 -05:00
  • e19d84b839 Added compile time check for store_offsets() api accelerated 2019-02-06 17:47:02 -05:00
  • 4f4c9e9c91 Changes per code review accelerated 2019-02-06 13:01:57 -05:00
  • 284e1c57a9 Changed store_offsets() to use the actual position from the assignment accelerated 2019-02-04 14:08:40 -05:00
  • 7bc03185a8 Added legacy offset store API accelerated 2019-02-04 12:10:45 -05:00
  • 872ee0442b Merge pull request #163 from accelerated/status_version_fix Matias Fontanini 2019-01-31 09:03:40 -08:00
  • 63327461bd Fix message status version accelerated 2019-01-31 09:29:48 -05:00
  • efa4e95a18 Merge pull request #157 from demin80/buffer-size-comparison-fix2 Matias Fontanini 2019-01-19 08:12:55 -08:00
  • 755e9f10c2 added missing return demin80 2019-01-18 16:58:03 -05:00
  • fb4c5edc8e Merge pull request #159 from accelerated/check_error_fix Matias Fontanini 2019-01-16 12:27:57 -08:00
  • dc732445f7 Fixes #158 accelerated 2019-01-16 15:09:27 -05:00
  • 5a34955fae added type conversion to avoid signed-vs-unsigned-comparison warning demin80 2019-01-16 10:52:14 -05:00
  • 05cc8304df Merge pull request #153 from demin80/hi-priority-queue-fix Matias Fontanini 2019-01-14 20:08:47 -08:00
  • 2c6a47d68d Merge pull request #156 from psigen/patch-1 Matias Fontanini 2019-01-14 09:18:50 -08:00
  • 85b7e579e2 Use CMAKE_STATIC_LIBRARY_* macros for FindRdKafka Pras Velagapudi 2019-01-12 15:51:11 -05:00
  • 93c2edf6ba refactored by adding retry_mutex_ and replacing bools with enums; fixed formatting issues demin80 2019-01-10 14:37:46 -05:00
  • 71c4e02143 Revised the implementation based on the reviewers' response demin80 2019-01-08 13:48:26 -05:00
  • 00370c981d Fixed spacing issues demin80 2019-01-07 14:42:32 -05:00
  • 97229ebfd9 Added a high-priority queue to BufferedProducer to avoid message re-ordering demin80 2019-01-07 14:39:09 -05:00
  • 4ba6b38b6e Merge pull request #149 from accelerated/queue_full Matias Fontanini 2019-01-06 16:52:12 -08:00
  • 4a6b6779ad Updated callback description accelerated 2019-01-06 17:40:39 -05:00
  • 97d1bb9434 Added queue full notify callback accelerated 2019-01-06 17:35:55 -05:00
  • ed81ce446d Added queue full notification accelerated 2018-12-13 13:05:11 -05:00
  • 520465510e Revert "Add support for Buffer construction via raw arrays" Matias Fontanini 2018-12-17 09:18:28 -08:00
  • 40ee64c5c1 Merge pull request #140 from tgaldes/master Matias Fontanini 2018-12-16 11:42:29 -08:00
  • 3ffb0f1fa8 Merge pull request #151 from mfontanini/travis-fix Matias Fontanini 2018-12-16 10:15:33 -08:00
  • 7c5616da07 Use sudo: required in travis file Matias Fontanini 2018-12-16 09:54:53 -08:00
  • f14a4b9e8c Merge pull request #150 from accelerated/flush_bug Matias Fontanini 2018-12-16 09:45:35 -08:00
  • ccc6738265 Merge pull request #148 from accelerated/flush_failure Matias Fontanini 2018-12-16 09:32:36 -08:00
  • 8b431c5421 changed rbegin to begin accelerated 2018-12-14 16:32:33 -05:00
  • 4a24971d3f Fixed bug with message leak in BufferedProducer::flush(timeout) accelerated 2018-12-14 16:08:57 -05:00
  • 8dd5428c49 Added similar logic for ProduceTerminationCallback accelerated 2018-12-13 11:48:34 -05:00
  • 0b9b7bab11 Added flush termination callback accelerated 2018-12-13 10:43:29 -05:00
  • ab002fe119 Merge pull request #147 from accelerated/raw_arrays Matias Fontanini 2018-12-10 18:15:37 -08:00
  • 06ddd79a29 Support for raw array Buffer constructor accelerated 2018-12-10 15:39:16 -05:00
  • d89840b5f0 Merge pull request #144 from accelerated/header_fix Matias Fontanini 2018-12-09 21:47:35 -08:00
  • 25c2eaa998 Changed iterator logic to capture header list by reference accelerated 2018-12-06 10:37:02 -05:00
  • 1c80af9b68 Added constructor from another HeaderList type accelerated 2018-12-05 20:04:10 -05:00
  • fe0c7e7dd5 Fixed end() iterator and also applied default copy-constructor instead of passing null handle in BasicMessageBuilder accelerated 2018-12-05 12:15:25 -05:00
  • 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. accelerated 2018-12-04 11:12:28 -05:00
  • 6bbddcd5d5 Fixed Message::set_header_list as per review comments. Changed ClonablePtr to use clone() internally accelerated 2018-12-03 08:53:25 -05:00
  • e96dc6d1fc Added comments accelerated 2018-12-02 15:00:07 -05:00
  • 0b7931bfb8 Added Buffer::Buffer(iter, iter) constructor overload accelerated 2018-12-02 14:42:02 -05:00
  • 57bddabfd0 Removed clone_handle method and made ClonablePtr::clone private accelerated 2018-12-02 14:15:20 -05:00
  • c7ba478582 Header fixes accelerated 2018-11-28 20:44:55 -05:00
  • a9a0693e2a Merge pull request #143 from mfontanini/fix-travis Matias Fontanini 2018-11-26 20:03:07 -08:00
  • 5aa4bc08a3 Fix kafka download URL in travis file Matias Fontanini 2018-11-26 19:47:58 -08:00
  • 5a4481dc28 Merge pull request #142 from farnazj/master Matias Fontanini 2018-11-26 19:06:45 -08:00
  • d06cd222fe include <array> Farnaz Jahanbakhsh 2018-11-26 00:26:04 +00:00
  • 74acf65fa6 Add support for Buffer construction via raw arrays Tyler Galdes 2018-11-19 19:59:08 -05:00
  • 4ad2685d61 Merge pull request #138 from tgaldes/master Matias Fontanini 2018-11-19 16:58:34 -08:00
  • 248d1b0638 Delete construction of buffer with rvalue arrays Tyler Galdes 2018-11-19 19:48:02 -05:00
  • b48036fe62 use std::array functions for pointer and size of data Tyler Galdes 2018-11-19 11:49:17 -05:00
  • 757d2b623f Add support for constructing Buffer from std::array Tyler Galdes 2018-11-16 19:49:52 -05:00
  • 4b7a10ec90 Merge pull request #136 from accelerated/master Matias Fontanini 2018-11-13 14:50:15 -08:00
  • b366cf4bf6 Remove setting log level in the constructor accelerated 2018-11-13 15:28:06 -05:00
  • 7b4c3e163f Merge pull request #135 from accelerated/events Matias Fontanini 2018-11-12 10:26:30 -08:00
  • 70aef6681d Added API description for Message::get_status accelerated 2018-11-12 12:14:20 -05:00
  • 29cb02b756 Merge pull request #134 from accelerated/events Matias Fontanini 2018-11-12 09:05:27 -08:00
  • 9859e54522 Added support for message status and setting the event mask accelerated 2018-11-12 10:30:54 -05:00
  • 9f6556da0c Merge pull request #125 from mfontanini/events Matias Fontanini 2018-11-10 10:43:05 -08:00
  • 46481d879f Use BufferedProducer in round robin consumer test Matias Fontanini 2018-10-27 11:14:22 -07:00
  • 25e3aacf4a Add compile guard for rd_kafka_event_stats Matias Fontanini 2018-10-27 10:43:58 -07:00
  • 1f1f1c253b Fix build issue when using rd_kafka_message_latency in old rdkafka Matias Fontanini 2018-10-27 10:33:57 -07:00
  • 24960c0a49 Build library on travis using rdkafka 0.9.4 as well Matias Fontanini 2018-10-27 09:53:46 -07:00
  • 4ac837d831 Disable even consumption test Matias Fontanini 2018-10-27 09:53:17 -07:00
  • b242e2c35c Allow setting background event callback on configuration handles Matias Fontanini 2018-10-27 09:46:13 -07:00
  • 19baa03cea Allow getting background queue out of kafka handle base Matias Fontanini 2018-10-27 09:34:42 -07:00
  • 8dc94869fd Move get_queue behavior into Queue class Matias Fontanini 2018-10-27 09:25:07 -07:00
  • 71fb76b8e1 Add dumb test that extracts event from queue Matias Fontanini 2018-10-21 15:17:48 -07:00
  • c7e1dcb60a Allow checking if an Event is valid Matias Fontanini 2018-10-21 11:36:16 -07:00
  • e73c997a0c Allow getting Events out of Queues Matias Fontanini 2018-10-21 11:32:52 -07:00
  • b46991db7e Add Event class Matias Fontanini 2018-10-21 11:31:41 -07:00
  • b0ddceda1f Message timestamp refactoring and log level changes (#133) Alex Damian 2018-11-07 11:36:57 -05:00
  • 451d60295a Remove MessageTimestamp constructor from time_point (#129) Matias Fontanini 2018-10-26 18:57:28 -07:00
  • 57268e666c Added time_point overloads for creating timestamps. (#128) Alex Damian 2018-10-25 10:39:22 -04:00
  • ad9a1e4a49 If timeout is 0, the function should at least run once (#123) Alex Damian 2018-10-22 10:55:29 -04:00
  • 416a7d43ce Minor documentation fixes Matias Fontanini 2018-10-21 10:17:10 -07:00
  • a2d17a6f45 Test suite fixes (#124) Matias Fontanini 2018-10-20 20:32:32 -07:00
  • 0d54acbc64 Flush producer in example Matias Fontanini 2018-10-19 08:42:10 -07:00
  • b2ba4cbfa3 Add comment regarding flushing producer Matias Fontanini 2018-10-19 08:41:36 -07:00
  • 2b66fd3a22 Fix windows linker errors (#120) multiprogramm 2018-10-17 20:43:33 +03:00
  • fbe3759fed Header support implementation (#115) Alex Damian 2018-10-16 13:58:05 -04:00
  • 9af4330c6d Allocators (#118) Alex Damian 2018-10-16 11:57:11 -04:00
  • d77e7466b8 changed assert with if statement (#116) Alex Damian 2018-10-06 12:28:45 -04:00