scottk/wlan-cloud-lib-cppkafka
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-cloud-lib-cppkafka.git synced 2025-12-25 14:37:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

Commit Graph

  • f458514fb2 Bump version to 0.2 0.2 Matias Fontanini 2018-09-20 18:23:32 -07:00
  • d3ef9cad32 Fix #111: Rename LogLevel enums (#112) Zenon Parker 2018-08-30 14:28:12 -04:00
  • df04b27e22 Fix #104: memory leak in poll_batch (#107) shashank khare 2018-07-26 16:56:42 +01:00
  • d6f8129207 Fix for ref count on queue handles (#92) Alex Damian 2018-07-23 20:07:35 -04:00
  • 3238c94f43 Fix #83: define LIBRDKAFKA_STATICLIB (#99) Sergey Batanov 2018-07-04 18:26:25 +03:00
  • 081f8d80a0 Fix #97: struct switched to class. (#98) Sergey Batanov 2018-07-03 02:57:52 +03:00
  • 577bbb0242 added error check for partition list (#90) Alex Damian 2018-06-26 11:57:49 -04:00
  • 6158d932c0 Example fixes (#96) Matias Fontanini 2018-06-25 19:19:23 -07:00
  • 5c72f3fe28 Added pause/resume for producers (#87) Alex Damian 2018-06-25 12:16:57 -04:00
  • 069ea3df8e Specific linking option for rdkafka library (#94) Alex Damian 2018-06-25 10:03:11 -04:00
  • c5aca985b8 Invoke error callback if present instead of log callback (#93) Alex Damian 2018-06-20 12:11:24 -04:00
  • eb46b8808e Bug fixes for sync flush and add_tracker (#91) Alex Damian 2018-06-18 17:46:31 -04:00
  • b8f4be5e1b Increase buffer construction requirements (#88) Alex Damian 2018-06-18 12:09:48 -04:00
  • 9a20b588c5 Merge pull request #86 from accelerated/flush_with_timeout Matias Fontanini 2018-06-14 10:14:44 -07:00
  • 3c72eb5752 Added timeout to flush and wait_for_acks accelerated 2018-06-14 11:43:12 -04:00
  • 157b7ec997 Merge pull request #79 from accelerated/purge Matias Fontanini 2018-06-12 09:30:58 -07:00
  • f220062e40 Changed purge to async_flush accelerated 2018-06-12 10:23:48 -04:00
  • 7530b9f9e4 added method to empty the buffer when max limit is reached accelerated 2018-06-07 14:09:17 -04:00
  • 3cf9bb53e9 Added purge (aka async_flush) functionality accelerated 2018-06-05 17:45:41 -04:00
  • 0c7a3b0c25 Merge pull request #78 from accelerated/producer_retry Matias Fontanini 2018-06-11 20:45:37 -07:00
  • 972a008aa4 Changed test to produce twice the same MessageBuilder accelerated 2018-06-11 15:45:41 -04:00
  • a4eefacaa1 concurrency issues in MessageBuilder internal data accelerated 2018-06-10 10:14:00 -04:00
  • 23810654ab Removed dependency on Producer and dr_callback_proxy accelerated 2018-06-06 19:15:34 -04:00
  • f746653841 Added logic to conditionally enable internal data accelerated 2018-06-05 09:07:00 -04:00
  • 597c026555 Prevent MessageInternal structures if there is no delivery callback registered accelerated 2018-06-04 17:12:07 -04:00
  • 71e6e2e4e5 added retry logic for producers accelerated 2018-06-01 15:55:52 -04:00
  • f15b59cb13 Fix compacted topic processor test Matias Fontanini 2018-06-09 14:49:50 -07:00
  • 5dcede6411 #81: add detail headers to installation (#82) sachnk 2018-06-09 13:32:10 -04:00
  • 5cad740aea Added access to the internal Consumer in the backoff committer (#75) Alex Damian 2018-06-04 14:48:20 -04:00
  • 9714bec5bf Callback invoker to sink all thrown exceptions (#74) Alex Damian 2018-06-01 19:35:56 -04:00
  • 15fdab6943 Merge pull request #63 from accelerated/partition_poll Matias Fontanini 2018-05-30 11:15:02 -07:00
  • ea9601ba1b Changes per code review accelerated 2018-05-17 11:06:23 -04:00
  • ffc64b9a5a Remove valgrind warning accelerated 2018-05-15 13:05:46 -04:00
  • 556f15a43f Allow access to the user-supplied delivery callback. accelerated 2018-05-15 11:18:22 -04:00
  • 6144330835 added test case for polling strategy refactored the strategy class accelerated 2018-05-07 19:19:15 -04:00
  • 169ea4f8ed Fixes to queue polling and making them non-owning accelerated 2018-05-02 15:31:34 -04:00
  • 65f35dcd39 fix cppkafka::MessageList declaration accelerated 2018-05-01 16:34:49 -04:00
  • 532d83b225 Removed reserve() and synced consumer::poll_batch and queue::poll_batch functions accelerated 2018-05-01 15:12:03 -04:00
  • a1ce130bfd changes as per code review accelerated 2018-05-01 14:49:09 -04:00
  • 71afaba3e1 added support for different topics/partitions accelerated 2018-04-30 20:11:25 -04:00
  • 15be627f8e intial polling version accelerated 2018-04-27 00:20:47 -04:00
  • 429ec92369 Buffered producer thread safe (#72) Alex Damian 2018-05-28 21:33:36 -04:00
  • f543810515 Allow metadata object to be non-owning (#73) Alex Damian 2018-05-28 14:30:01 -04:00
  • 841e632fbd Allow access to the user-supplied delivery callback. (#66) Alex Damian 2018-05-24 23:59:41 -04:00
  • 46c396f729 Pause/resume a consumer by topic (#67) Alex Damian 2018-05-23 16:03:47 -04:00
  • ee71b3979a Add yield (#64) amirshavit 2018-05-23 17:26:09 +01:00
  • d9feb5c3db Added retry limit for the backoff performer class (#70) Alex Damian 2018-05-23 12:16:12 -04:00
  • 2451c74c4f Avoid SIGSEGV during destructing KafkaHandleBase (with set_log_callback()) (#68) Azat Khuzhin 2018-05-19 23:24:57 +03:00
  • ae74814791 Log error in case consumer destructor throws (#61) Alex Damian 2018-04-27 10:03:47 -04:00
  • ee0c0829a4 Remove extra line at the end of cppkafka.h Matias Fontanini 2018-04-23 19:23:09 -07:00
  • 59d8adc4a4 Sort header files before generating cppkafka.h Matias Fontanini 2018-04-23 19:22:41 -07:00
  • cb2c8877d8 Move tests to use catch instead of googletest (#56) Matias Fontanini 2018-04-24 03:20:48 +01:00
  • 30b3652a94 auto-gen main header file (#59) Alex Damian 2018-04-23 21:32:43 -04:00
  • 8fc6a0f02d Print offset when dumping partition object (#55) Alex Damian 2018-04-23 21:32:14 -04:00
  • 83a963c1db Added commit for current assignment and message state checks (#53) Alex Damian 2018-04-20 18:51:44 -04:00
  • c95d790547 Added cmake option for disabling tests (#51) Andrei Ovsiankin 2018-04-20 15:00:34 +03:00
  • eee60407fa Use CPPKAFKA_API for friends and free functions Matias Fontanini 2018-04-11 10:47:53 -07:00
  • 05d5a0404b Merge pull request #47 from accelerated/master Matias Fontanini 2018-04-03 19:04:39 -07:00
  • 3d1402f53a Fixed font accelerated 2018-04-03 12:04:26 -04:00
  • 6db2cdcecf Fixed font accelerated 2018-04-03 12:02:21 -04:00
  • 018a1f52d9 Fixed deprecated error librdkafka function accelerated 2018-04-03 11:58:21 -04:00
  • df12b5fd5c Fix linking issues on Windows Matias Fontanini 2018-03-20 08:12:04 -07:00
  • 9513b01b8e Don't use quotes when expanding DEPENDENCIES Matias Fontanini 2018-03-19 07:04:59 -07:00
  • 86ed154c92 Link with ws2_32.lib on Windows Matias Fontanini 2018-03-18 18:57:09 -07:00
  • 69e30f9e74 Merge pull request #39 from arvidn/destruction Matias Fontanini 2018-03-17 15:42:21 -07:00
  • 675954ef75 Merge pull request #40 from arvidn/poll-batch-performance Matias Fontanini 2018-03-17 15:41:21 -07:00
  • 98b9839ff9 improve performance of Consumer::poll_batch() by allocating the results array once, rather than incremental growth. Also avoid checking every single pointer in the returned array, just use the returned counter instead arvidn 2018-02-08 12:21:13 +01:00
  • d173526f99 destruct callbacks (and their closures) to ensure there are no reference cycles when destructing the consumer. This solves a hang in rd_kafka_destroy arvidn 2018-02-08 11:51:36 +01:00
  • deff8b1ff3 Merge pull request #27 from alkenet/patch-1 Matias Fontanini 2017-11-28 20:28:00 -08:00
  • cc7d183ff1 Update README.md atravers 2017-11-29 13:03:02 +09:00
  • 1817115784 Merge pull request #22 from mfontanini/mfontanini-patch-1 Matias Fontanini 2017-11-21 09:19:21 -08:00
  • 9c09243633 Use latest kafka version in travis Matias Fontanini 2017-11-21 06:51:53 -08:00
  • 5b63c642f9 Merge pull request #21 from spektom/patch-1 Matias Fontanini 2017-11-21 06:47:23 -08:00
  • c874ccc43f Check for existing custom target: uninstall Michael Spector 2017-11-21 10:14:29 +02:00
  • af368bba04 Merge pull request #16 from arvidn/include-dir Matias Fontanini 2017-11-11 14:02:32 -08:00
  • c7715733bf make sure dependent targets get the include directory added correctly arvidn 2017-10-24 22:21:44 +02:00
  • 80e0ed5007 Merge pull request #18 from arvidn/consumer-typo Matias Fontanini 2017-10-25 11:28:56 -07:00
  • a1dc9d115e fix typo in consumer documentation arvidn 2017-10-25 20:26:35 +02:00
  • edb2737263 Merge pull request #17 from arvidn/typo Matias Fontanini 2017-10-24 14:08:05 -07:00
  • 5bd61e8915 fix typo in README arvidn 2017-10-24 22:26:54 +02:00
  • 0e96f87eeb Wait for kafka to come up in travis build Matias Fontanini 2017-10-14 10:40:36 -07:00
  • 702279d0e9 Add travis CI badge to README.md Matias Fontanini 2017-10-14 10:28:42 -07:00
  • 94dac08d79 Merge pull request #14 from mfontanini/travis Matias Fontanini 2017-10-14 10:28:25 -07:00
  • 29fa7bed19 Add travis CI build file Matias Fontanini 2017-10-14 08:39:53 -07:00
  • 179e669c06 Assume testing kafka cluster is >= 0.10 Matias Fontanini 2017-10-14 08:38:43 -07:00
  • 853396acab Fix Consumer::poll_batch test Matias Fontanini 2017-10-14 08:28:51 -07:00
  • 5889c322c2 Fix link issues when building in clang Matias Fontanini 2017-10-02 10:30:28 -07:00
  • 17da880854 Persist message's user data when retrying on buffered producer Matias Fontanini 2017-09-17 15:46:23 -07:00
  • 4c9aa6fcd4 Catch exceptions on Consumer destructor Matias Fontanini 2017-09-14 19:26:23 -07:00
  • 37cb16c3f5 Check for null pointer on Consumer::poll_batch Matias Fontanini 2017-09-06 23:44:34 -07:00
  • 04d5b41c6b Add a project description to README.md Matias Fontanini 2017-08-28 21:29:35 -07:00
  • c3011c9eed Remove redundant line in README.md Matias Fontanini 2017-08-28 21:24:20 -07:00
  • d0c794b978 Increase expected acks on buffered producer after producing Matias Fontanini 2017-08-24 15:04:54 -07:00
  • 86d4bc8037 Make BasicConsumerDispatcher::Pauser a template type Matias Fontanini 2017-08-21 14:47:06 -07:00
  • 0d4b9ef2f6 Don't keep looping on NO_OFFSET error on backoff committer Matias Fontanini 2017-08-03 09:33:09 -07:00
  • 1582f6156d Allow consuming message batches Matias Fontanini 2017-07-17 19:17:49 -07:00
  • 2340046544 Clear messages acked/expected acks on buffered producer Matias Fontanini 2017-07-11 10:17:58 -07:00
  • b7a0dce710 Add a generic "event" event on ConsumerDispatcher Matias Fontanini 2017-07-04 18:23:42 -07:00
  • 08815e97c0 Add CPPKAFKA_API to utils classes Matias Fontanini 2017-07-04 18:09:06 -07:00
  • 9e6315fcc2 Make ConsumerDispatcher a template class Matias Fontanini 2017-07-04 18:07:22 -07:00