mre /
kafka-influxdb
| ⇢ | A | KafkaError added | |
| ⇢ | A | TestConfluentKafka added | |
| ⇢ | A | ReaderAbstract added | |
| ⇢ | A | TestKafkaPython added | |
| ⇢ | A | TestWorker added | |
| A | ↛ | KafkaSampleWriter removed | |
| A | ↛ | DummyWriter removed | |
| A | ↛ | KafkaReader removed | |
| A | ↛ | TestKafkaReader removed | |
| A | ↛ | TestKafkaInfluxDB removed |
| ⇢ | A | ReaderAbstract.__init__() added | |
| ⇢ | A | TestWorker.test_reconnect() added | |
| ⇢ | A | ReaderAbstract._connect() added | |
| ⇢ | A | TestWorker.setUp() added | |
| ⇢ | A | ReaderAbstract._handle_read() added | |
| ⇢ | A | ReaderAbstract.read() added | |
| ⇢ | A | Reader._handle_error() added | |
| ⇢ | A | Reader._connect() added | |
| ⇢ | A | Reader._subscribe() added | |
| ⇢ | A | Reader._setup_connection() added | |
| ⋮ | view more | ||
| A | ↘ | B | Worker.consume() got worse |
| A | ↛ | KafkaSampleWriter._send_requests() removed | |
| A | ↛ | KafkaSampleWriter._send_request_batches() removed | |
| A | ↛ | TestKafkaInfluxDB.setUp() removed | |
| A | ↛ | TestKafkaInfluxDB.test_buffering() removed | |
| A | ↛ | TestKafkaReader.setUp() removed | |
| A | ↛ | KafkaReader._connect() removed | |
| A | ↛ | KafkaReader.read() removed | |
| A | ↛ | KafkaReader._handle_read() removed | |
| A | ↛ | KafkaReader.__init__() removed | |
| A | ↛ | TestKafkaReader.test_handle_read() removed | |
| ⋮ | view more | ||
