version 0.14

uperl · Oct 21, 2019 · 1c056a6 · 1c056a6
1 parent cee2fd6
commit 1c056a6
Show file tree

Hide file tree

Showing 4 changed files with 16 additions and 1 deletion.
diff --git a/Changes b/Changes
@@ -1,5 +1,8 @@
 Revision history for Kafka-Librd
 
+0.14 2019-10-20 19:50:39 -0600
+  - Aded flush and destroy methods (gh#19, miket++)
+
 0.12 2019-07-26 15:25:57 -0400
   - Added timestamp method (gh#10, gh#14, eserte++)
 

diff --git a/MANIFEST b/MANIFEST
@@ -14,7 +14,9 @@ rdkafkaxs.c
 rdkafkaxs.h
 README
 t/00-load.t
+t/basic.t
 t/constants.t
+t/errors.t
 typemap
 utils/generate_const.pl
 xt/manifest.t

diff --git a/README b/README
@@ -130,6 +130,11 @@ METHODS
 
     return the current out queue length.
 
+  flush
+        $kafka->flush($timeout_ms)
+
+    wait until all outstanding produce requests, et.al, are completed.
+
   destroy
         $kafka->destroy
 
@@ -153,6 +158,11 @@ Kafka::Librd::Topic
     and RD_KAFKA_MSG_F_FREE must not be used, internally RD_KAFKA_MSG_F_COPY
     is always set.
 
+  destroy
+        $topic->destroy
+
+    destroy topic handle
+
 Kafka::Librd::Message
     This class maps to "rd_kafka_message_t" structure from librdkafka and
     represents message or event. Objects of this class have the following

diff --git a/lib/Kafka/Librd.pm b/lib/Kafka/Librd.pm
@@ -3,7 +3,7 @@ package Kafka::Librd;
 use strict;
 use warnings;
 
-our $VERSION = '0.12';
+our $VERSION = '0.14';
 
 require XSLoader;
 XSLoader::load('Kafka::Librd', $VERSION);