From 1c056a6bd4ef17379db1a41f99311de21856dbf4 Mon Sep 17 00:00:00 2001 From: Graham Ollis Date: Sun, 20 Oct 2019 19:53:27 -0600 Subject: [PATCH] version 0.14 --- Changes | 3 +++ MANIFEST | 2 ++ README | 10 ++++++++++ lib/Kafka/Librd.pm | 2 +- 4 files changed, 16 insertions(+), 1 deletion(-) diff --git a/Changes b/Changes index 0dda9aa..af2d8f1 100644 --- 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 index 9b96d20..7a427e9 100644 --- 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 index 2da4ee7..a1fa26d 100644 --- 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 index 76c1940..a3ee116 100644 --- 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);