This is an automated email from the ASF dual-hosted git repository.
rabbah pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/openwhisk-package-kafka.git
The following commit(s) were added to refs/heads/master by this push:
new d354b60 Use latest Kafka client (#363)
d354b60 is described below
commit d354b60fbcaa949e2e6dc3d57bd56449471c5f80
Author: James Dubee <[email protected]>
AuthorDate: Sat May 23 18:32:32 2020 -0400
Use latest Kafka client (#363)
---
Dockerfile | 2 +-
provider/consumer.py | 3 ++-
2 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/Dockerfile b/Dockerfile
index fab7018..0c73922 100644
--- a/Dockerfile
+++ b/Dockerfile
@@ -20,7 +20,7 @@ FROM python:2.7.16
RUN apt-get update && apt-get upgrade -y
# install librdkafka
-ENV LIBRDKAFKA_VERSION 1.2.0
+ENV LIBRDKAFKA_VERSION 1.3.0
RUN git clone --depth 1 --branch v${LIBRDKAFKA_VERSION}
https://github.com/edenhill/librdkafka.git librdkafka \
&& cd librdkafka \
&& ./configure \
diff --git a/provider/consumer.py b/provider/consumer.py
index 477b75d..d525c84 100644
--- a/provider/consumer.py
+++ b/provider/consumer.py
@@ -299,7 +299,8 @@ class ConsumerProcess (Process):
'group.id': self.trigger,
'default.topic.config': {'auto.offset.reset':
'latest'},
'enable.auto.commit': False,
- 'api.version.request': True
+ 'api.version.request': True,
+ 'isolation.level': 'read_uncommitted'
}
if self.isMessageHub:
