In order to send and read user json data through kafka,

[b1ueseanoah]

In order to send and read user json data through kafka,
we will change the source that sets consumer and producer of kafka.

[b1ueseanoah]

we changed the source code that sets consumer and producer of gedge kafka.

def set_producer(self):
    self.producer= KafkaProducer(acks=0, 
                compression_type='gzip', 
                bootstrap_servers=self.bootstrap_servers, 
                value_serializer=lambda x: json.dumps(x).encode('utf-8')) 

def set_consumer(self, topic_name, groupId):    
    self.consumer = KafkaConsumer(
            topic_name,
            bootstrap_servers   = self.bootstrap_servers, 
            group_id            = groupId,
            #enable_auto_commit  = True,
            enable_auto_commit  = False,
            auto_offset_reset   = 'earliest',
            value_deserializer  = lambda x: json.loads(x.decode('utf-8')), 
            consumer_timeout_ms = gDefine.CONSUMER_TIMEOUT_MS_TIME
        )