Aiven-Open / Aiven-Open/cloud-storage-connectors-for-apache-kafka
Record Groupers interface should have a clearFileBuffers method
Abierto
- Lenguaje dominante
- Java
- Estrellas
- 58
- Forks
- 39
- Merge medio
- 2 d 10 h
- PR fusionados (30 d)
- 5
Descripción
In the last few months the sink connectors have been updated to use a new way of uploading data that reduces memory held and speeds up the transfer process.
As part of this a new method ` void clearFileBuffers(final String recordKey)` has been added to some Record groupers.
This method should be added to the `RecordGrouper` interface and throw a `NotImplementedException` on the Record Groupers which do not use this method.
Guía de contribución
Evaluación
Este issue todavía no se ha evaluado.