updated kafka protocol for recent changes (#140)

skywalking/agent/protocol/kafka.py

@@ -37,9 +37,6 @@ def __init__(self):
         self.service_management = KafkaServiceManagementClient()
         self.traces_reporter = KafkaTraceSegmentReportService()
 
-    def connected(self):
-        return True
-
     def heartbeat(self):
         self.service_management.send_heart_beat()
 
@@ -52,7 +49,7 @@ def generator():
                     timeout = config.QUEUE_TIMEOUT - int(time() - start)  # type: int
                     if timeout <= 0:  # this is to make sure we exit eventually instead of being fed continuously
                         return
-                    segment = queue.get(block=block)  # type: Segment
+                    segment = queue.get(block=block, timeout=timeout)  # type: Segment
                 except Empty:
                     return