diff options
Diffstat (limited to 'kafka/producer/sender.py')
| -rw-r--r-- | kafka/producer/sender.py | 17 |
1 files changed, 0 insertions, 17 deletions
diff --git a/kafka/producer/sender.py b/kafka/producer/sender.py index aafa06a..2974faf 100644 --- a/kafka/producer/sender.py +++ b/kafka/producer/sender.py @@ -204,7 +204,6 @@ class Sender(threading.Thread): batch = batches_by_partition[tp] self._complete_batch(batch, error, offset, ts) - self._sensors.record_latency((time.time() - send_time) * 1000, node=node_id) if response.API_VERSION > 0: self._sensors.record_throttle_time(response.throttle_time_ms, node=node_id) @@ -343,15 +342,6 @@ class SenderMetrics(object): sensor_name=sensor_name, description='The maximum time in ms record batches spent in the record accumulator.') - sensor_name = 'request-time' - self.request_time_sensor = self.metrics.sensor(sensor_name) - self.add_metric('request-latency-avg', Avg(), - sensor_name=sensor_name, - description='The average request latency in ms') - self.add_metric('request-latency-max', Max(), - sensor_name=sensor_name, - description='The maximum request latency in ms') - sensor_name = 'produce-throttle-time' self.produce_throttle_time_sensor = self.metrics.sensor(sensor_name) self.add_metric('produce-throttle-time-avg', Avg(), @@ -498,12 +488,5 @@ class SenderMetrics(object): if sensor: sensor.record(count) - def record_latency(self, latency, node=None): - self.request_time_sensor.record(latency) - if node is not None: - sensor = self.metrics.get_sensor('node-' + str(node) + '.latency') - if sensor: - sensor.record(latency) - def record_throttle_time(self, throttle_time_ms, node=None): self.produce_throttle_time_sensor.record(throttle_time_ms) |