Aiven-Open / Aiven-Open/cloud-storage-connectors-for-apache-kafka

Record Groupers interface should have a clearFileBuffers method

Abierto
#626 0 comentarios 0 reacciones 0 asignados Ver en GitHub
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

Abrir la guía de contribución

Evaluación

Este issue todavía no se ha evaluado.

Recibe los nuevos issues en tu correo

Un resumen breve de issues de GitHub para principiantes.