Alexander Damian a4532ed336 Use erase directly ...

Added revoke() member function

2020-02-09 21:25:36 -05:00

..

utils

Use erase directly

2020-02-09 21:25:36 -05:00

buffer.cpp

Header support implementation (#115)

2018-10-16 10:58:05 -07:00

CMakeLists.txt

Updated pkg_config file name

2019-07-17 10:20:43 -04:00

configuration_option.cpp

Update license

2017-05-06 08:27:47 -07:00

configuration.cpp

Added support for message status and setting the event mask

2018-11-12 10:30:54 -05:00

consumer.cpp

Added compile time check for store_offsets() api

2019-02-06 17:47:02 -05:00

error.cpp

Update license

2017-05-06 08:27:47 -07:00

event.cpp

Add compile guard for rd_kafka_event_stats

2018-11-10 10:26:03 -08:00

exceptions.cpp

Define constructor for new exception

2019-05-17 09:14:35 -07:00

group_information.cpp

Move endianness.h file into detail folder

2017-06-05 19:36:22 -07:00

kafka_handle_base.cpp

Fixes #158

2019-01-16 15:09:27 -05:00

message_internal.cpp

concurrency issues in MessageBuilder internal data

2018-06-10 18:48:51 -04:00

message_timestamp.cpp

Message timestamp refactoring and log level changes (#133)

2018-11-07 08:36:57 -08:00

message.cpp

Message timestamp refactoring and log level changes (#133)

2018-11-07 08:36:57 -08:00

metadata.cpp

Allow metadata object to be non-owning (#73)

2018-05-28 11:30:01 -07:00

producer.cpp

* Added asserts when building a HeaderList and removed checks for handle

2018-12-04 11:12:28 -05:00

queue.cpp

Move get_queue behavior into Queue class

2018-11-10 10:25:31 -08:00

topic_configuration.cpp

Callback invoker to sink all thrown exceptions (#74)

2018-06-01 16:35:56 -07:00

topic_partition_list.cpp

Replaced termination callback with throwing exception

2019-04-24 10:40:29 -04:00

topic_partition.cpp

Added method to set the partition

2019-07-26 10:35:20 -04:00

topic.cpp

intial polling version

2018-05-29 09:55:29 -04:00