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 | Reader._subscribe() added | |
| ⇢ | A | Reader._setup_connection() added | |
| ⇢ | A | TestConfluentKafka.create_kafka_message() added | |
| ⇢ | A | Reader._handle_read() added | |
| ⇢ | A | TestKafkaPython.setUp() added | |
| ⇢ | A | TestConfluentKafka.create_reader() added | |
| ⇢ | A | TestKafkaPython.test_handle_read() added | |
| ⇢ | A | TestConfluentKafka.test_handle_read() added | |
| ⇢ | A | TestKafkaPython.create_reader() added | |
| ⇢ | A | KafkaError.__init__() added | |
| ⋮ | view more | ||
| A | ↘ | B | Worker.consume() got worse |
| 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 | |
| A | ↛ | KafkaSampleWriter.produce_messages() removed | |
| A | ↛ | TestKafkaReader.test_reconnect() removed | |
| A | ↛ | KafkaSampleWriter.__init__() removed | |
| ⋮ | view more | ||
