Kafka-connector: bug fix and version update 0.2.4->0.2.5

ashutoshdtu · Mar 7, 2019 · 60998be · 60998be
1 parent c90485f
commit 60998be
Show file tree

Hide file tree

Showing 5 changed files with 5 additions and 5 deletions.
diff --git a/HISTORY.rst b/HISTORY.rst
@@ -2,7 +2,7 @@
 History
 =======
 
-0.2.4 (2019-02-23)
+0.2.5 (2019-02-23)
 ------------------
 
 * Cross-platform: Windows, Mac, and Linux are officially supported.

diff --git a/VERSION b/VERSION
@@ -1 +1 @@
-0.2.4
+0.2.5
diff --git a/src/eazyserver/__init__.py b/src/eazyserver/__init__.py
@@ -13,7 +13,7 @@
 
 __author__ = """Ashutosh Mishra"""
 __email__ = 'ashutoshdtu@gmail.com'
-__version__ = '0.2.4'
+__version__ = '0.2.5'
 
 
 import logging

diff --git a/src/eazyserver/core/kafka_connector.py b/src/eazyserver/core/kafka_connector.py
@@ -28,7 +28,7 @@ def kafka_to_dict(kafka_msg):
 def dict_to_kafka(output,source_data):
 	for data in source_data:
 		if output["source_id"] == data["_id"]:
-			output["_kafka_source_id"] = msg["_kafka__id"]
+			output["_kafka_source_id"] = data["_kafka__id"]
 			break
 	kafka_msg = dict_to_binary(json.dumps(output))
 	return kafka_msg

diff --git a/src/eazyserver/settings.ini b/src/eazyserver/settings.ini
@@ -1,6 +1,6 @@
 NAME = "eazyserver"
 DESCRIPTION = "Python Flask based REST/JsonRPC server."
-VERSION = "0.2.4"
+VERSION = "0.2.5"
 API_VERSION = 'v1'
 
 REST_BASE_ROUTE = "rest"