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

  • 191956b4ca Pause/resume consumption on throttle Matias Fontanini 2017-06-17 09:39:50 -07:00
  • 4af48ff0e7 Allow throttling on ConsumerDispatcher Matias Fontanini 2017-06-17 08:52:48 -07:00
  • 556dac7015 Add backoff performer class Matias Fontanini 2017-06-16 19:27:18 -07:00
  • 4cd03aea3c Cleanup ConsumerDispatcher code Matias Fontanini 2017-06-11 14:35:33 -07:00
  • 2e6bfd64d3 Fix comment typo Matias Fontanini 2017-06-10 19:37:48 -07:00
  • ed71ab2daa Add example using ConsumerDispatcher Matias Fontanini 2017-06-10 19:26:42 -07:00
  • 52822fdb61 Move some small functions into header files Matias Fontanini 2017-06-10 19:15:53 -07:00
  • bb5fb490ce Check if all callbacks match a signature on ConsumerDispatcher Matias Fontanini 2017-06-10 17:55:17 -07:00
  • 4369b75695 Use tags on EOF and timeout callbacks on ConsumerDispatcher Matias Fontanini 2017-06-10 17:39:23 -07:00
  • f0ec0bfb10 Add ConsumerDispatcher class Matias Fontanini 2017-06-10 15:25:28 -07:00
  • 67022dbb68 Add notes about static building on README.md v0.1 Matias Fontanini 2017-06-05 19:41:46 -07:00
  • d458e4d668 Add uninstall target Matias Fontanini 2017-06-05 19:38:34 -07:00
  • b79a1ae6da Move endianness.h file into detail folder Matias Fontanini 2017-06-05 19:36:22 -07:00
  • 000a119daf Add short options to kafka producer example Matias Fontanini 2017-06-05 19:30:51 -07:00
  • e741f40fbb Allow showing the member assignment in consumers info example Matias Fontanini 2017-06-05 19:29:11 -07:00
  • 67cad942ca Add consumer groups information example Matias Fontanini 2017-06-04 11:31:40 -07:00
  • 7d3b33d9cb Cleanup metadata example Matias Fontanini 2017-06-04 11:27:55 -07:00
  • 45c73a1f0c Use Producer rather than Consumer in metadata example Matias Fontanini 2017-06-04 11:20:40 -07:00
  • 56d594d232 Add metadata fetching example Matias Fontanini 2017-06-04 11:10:27 -07:00
  • acbae757d8 Remove all references to Partition class Matias Fontanini 2017-06-04 10:57:28 -07:00
  • 895a983d17 Allow constructing Buffers from std::vector Matias Fontanini 2017-06-04 08:31:57 -07:00
  • c58a4792d3 Update README.md Matias Fontanini 2017-06-03 12:45:11 -07:00
  • d88e2d9ed4 Fix build issue on Windows Matias Fontanini 2017-06-03 12:38:54 -07:00
  • 2f9170e32a Fix build errors/warnings on Windows Matias Fontanini 2017-06-03 12:23:06 -07:00
  • b5225926b4 Make FindRdKafka.cmake work on Windows Matias Fontanini 2017-06-03 12:06:41 -07:00
  • 9c9d1e494d Add BackoffCommitter class Matias Fontanini 2017-05-07 11:37:07 -07:00
  • 9594ddced3 Update license Matias Fontanini 2017-05-06 08:27:47 -07:00
  • bb900f21cb Allow clearing buffered messages on buffered producer Matias Fontanini 2017-04-24 20:08:26 -07:00
  • 5e84da2458 Change logic to reset messages acked count on buffered producer Matias Fontanini 2017-04-23 14:55:33 -07:00
  • 7ec3252a86 Minor documentation improvements Matias Fontanini 2017-04-23 14:24:06 -07:00
  • 03189b82a1 Minor fixes on examples Matias Fontanini 2017-04-23 14:21:49 -07:00
  • b5a7c70993 Expand description of BufferedProducer Matias Fontanini 2017-04-23 14:12:00 -07:00
  • aab182c4ea Allow producing messages without buffering them in buffered producer Matias Fontanini 2017-04-23 11:23:37 -07:00
  • 35cf6fd0bf Catch flush timeout exception on buffered producer Matias Fontanini 2017-04-23 11:06:49 -07:00
  • e7db3df966 Change internals of BufferedProducer Matias Fontanini 2017-04-23 11:01:21 -07:00
  • dbb547889b Allow getting consumer group information Matias Fontanini 2017-04-16 19:45:03 -07:00
  • ebde747e18 Multiple fixes on README.md Matias Fontanini 2017-04-16 15:41:08 -07:00
  • 6e248e2bb5 Update list of requirements in README Matias Fontanini 2017-04-16 15:34:07 -07:00
  • 88dd16e0e7 Update code on README.md Matias Fontanini 2017-04-16 15:33:38 -07:00
  • 69b0f2166b Update minimum librdkafka required version Matias Fontanini 2017-04-16 15:23:05 -07:00
  • 6c47b1a190 Allow setting timestamp on produced messages Matias Fontanini 2017-04-16 15:22:17 -07:00
  • 9ecad71be1 Remove Partition class Matias Fontanini 2017-04-16 14:51:06 -07:00
  • f5c8c7c3c8 Require rdkafka v0.9.4 to build Matias Fontanini 2017-04-16 10:29:15 -07:00
  • f924eb68e7 Allow making no key/payload copies in BufferedProducer Matias Fontanini 2017-04-16 10:13:14 -07:00
  • f781afe5cf Allow using generic message builders not tied to Buffer class Matias Fontanini 2017-04-16 09:47:39 -07:00
  • 861e41a792 Add note about the API being unstable Matias Fontanini 2017-04-15 19:25:40 -07:00
  • 8143c5b06a Add KafkaHandleBase::get_offsets_for_times Matias Fontanini 2017-04-15 19:21:51 -07:00
  • c9f3b0c5bc Use std::chrono::milliseconds for message timestamp Matias Fontanini 2017-04-15 18:14:36 -07:00
  • 91cd9a2957 Make producer test work on librdkafka v0.9.4 Matias Fontanini 2017-04-15 18:13:56 -07:00
  • c99c8bbb05 Add CPPKAFKA_API macro to MessageBuilder declaration Matias Fontanini 2017-04-15 17:25:31 -07:00
  • 401a60d016 Fix README.md to use MessageBuilder Matias Fontanini 2017-04-15 17:17:07 -07:00
  • 28f6253cfb Allow fetching metadata only for known topics Matias Fontanini 2017-04-15 16:53:37 -07:00
  • e26d7e7db2 Add MessageBuilder and use it on producer classes Matias Fontanini 2017-04-15 16:46:37 -07:00
  • c8154ac6cb Rename TopicMetadata::get_topic to TopicMetadata::get_name Matias Fontanini 2016-11-25 10:18:21 -08:00
  • 6f60881d87 Handle producer queue being full on buffered producer Matias Fontanini 2016-11-07 07:32:40 -08:00
  • aa7fa6ce0d Make Buffer::operator== a free function Matias Fontanini 2016-11-06 13:50:50 -08:00
  • 33680839a2 Include message.h in buffered_producer.h Matias Fontanini 2016-11-01 16:48:18 -07:00
  • ad1db4a680 Use relative includes on utils files Matias Fontanini 2016-11-01 15:50:40 -07:00
  • b570d07fcd Add compacted topic processor test Matias Fontanini 2016-10-29 13:20:25 -07:00
  • 55f93e1f0d Add buffered producer class Matias Fontanini 2016-10-29 11:29:26 -07:00
  • cf6dc03eec Move compacted topic processor into utils directory Matias Fontanini 2016-10-28 07:24:26 -07:00
  • b834fbd07a Use optionals for CompactedTopicProcessor decoders Matias Fontanini 2016-10-20 15:18:46 -07:00
  • 23f151175d Add wrapper for rd_kafka_outq_len Matias Fontanini 2016-10-08 10:24:15 -07:00
  • a46896790b Allow polling with a timeout Matias Fontanini 2016-10-08 10:08:15 -07:00
  • 8361e4ca1e Use another name for Metadata::get_topics when using a prefix Matias Fontanini 2016-08-19 14:12:44 -07:00
  • b768d52791 Take key before value on Producer::produce Matias Fontanini 2016-08-14 15:49:23 -07:00
  • af72add34c Remove bogus code Matias Fontanini 2016-08-11 19:57:57 -07:00
  • 0b252ddd6e Remove "in development" message from README.md Matias Fontanini 2016-08-11 19:49:59 -07:00
  • b147123eba Add Doxygen documentation generation Matias Fontanini 2016-07-30 09:15:14 -07:00
  • db1c99c662 Generate the proper .so version Matias Fontanini 2016-07-27 20:27:22 -07:00
  • ab44f5d1de Remove useless topic.h include in message.h Matias Fontanini 2016-07-23 14:27:44 -07:00
  • c3d6ce99f5 Make Consumer::close private Matias Fontanini 2016-07-16 08:45:33 -07:00
  • 06c50f0f71 Use include directory for rdkafka Matias Fontanini 2016-07-06 16:16:04 -07:00
  • 065f899954 Add error handler to compacted topic processor Matias Fontanini 2016-07-03 08:32:13 -07:00
  • cf6ac1675b Add Error class Matias Fontanini 2016-06-27 21:43:20 -07:00
  • 6cfe01afb1 Add CompactedTopicProcessor Matias Fontanini 2016-06-27 12:16:46 -07:00
  • ab9c2494e1 Add TopicPartition::operator< Matias Fontanini 2016-06-26 13:27:16 -07:00
  • 25ae15444e Add TopicPartition::set_offset Matias Fontanini 2016-06-26 09:06:09 -07:00
  • c878049253 Allow building a configuration from an option list Matias Fontanini 2016-06-25 09:24:18 -07:00
  • a2e7f6db0d Add getters for Consumer callbacks Matias Fontanini 2016-06-25 08:42:04 -07:00
  • c300a9bf35 Allow chaining set calls on Configuration and TopicConfiguration Matias Fontanini 2016-06-22 20:03:28 -07:00
  • bba9043faf Allow getting option values providing a template type Matias Fontanini 2016-06-20 20:07:10 -07:00
  • 0a58fc306b Fix build issues on OSX Matias Fontanini 2016-06-20 13:31:15 -07:00
  • c615664f12 Add Message::get_timestamp Matias Fontanini 2016-06-19 21:00:25 -07:00
  • 831111812e Export symbols on Windows dll builds Matias Fontanini 2016-06-19 09:46:28 -07:00
  • 678ac88c9b Add KafkaHandleBase::add_brokers Matias Fontanini 2016-06-19 09:21:29 -07:00
  • 68229af8c7 Update README.md Matias Fontanini 2016-06-19 09:21:20 -07:00
  • a3b311fe00 Make get_metadata(Topic) return only topic metadata Matias Fontanini 2016-06-18 08:45:33 -07:00
  • 84d98b38e5 Allow dumping all options in a configuration Matias Fontanini 2016-06-18 08:23:25 -07:00
  • 2532a2d614 Allow building as static/dynamic library Matias Fontanini 2016-06-17 15:51:34 -07:00
  • a12c0eb1f8 Check for rd_kafka_commited to check for valid rdkafka version Matias Fontanini 2016-06-17 15:47:26 -07:00
  • ac90aebfe5 Remove JSON library Matias Fontanini 2016-06-16 20:28:31 -07:00
  • 9738e3d90d Print assigned and revoked partitions on consumer example Matias Fontanini 2016-06-16 20:27:35 -07:00
  • 0fb0afc4f4 Remove zookeeper support Matias Fontanini 2016-06-16 20:22:36 -07:00
  • e1c2ee34fe Add iterators to Buffer Matias Fontanini 2016-06-16 07:46:55 -07:00
  • 8db1df0998 Add conversion/comparison operators to Buffer Matias Fontanini 2016-06-15 20:47:40 -07:00
  • 9e79321a1f Add operator<< for TopicPartition Matias Fontanini 2016-06-15 07:44:28 -07:00
  • 6877c4be03 Add enum for TopicPartition offsets Matias Fontanini 2016-06-15 07:32:22 -07:00
  • 74eb74785d Improve build system a bit Matias Fontanini 2016-06-14 21:03:07 -07:00
  • 387438fc74 Update README.md Matias Fontanini 2016-06-14 20:52:27 -07:00