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