Aiven-Open / Aiven-Open/aiven-kafka-connector-framework
Improve ability to manipulate the records in the EvolvingSourceRecord
- Vorherrschende Sprache
- Java
- Sterne
- 0
- Forks
- 3
- Ø Merge
- 3 Std. 12 Min.
- Gemergte PRs (30 T.)
- 3
Beschreibung
# What is currently missing?
An easy ability to get data from the Evolving Source record that could help improve the processing of data quickly.
# How could this be improved?
> public T getValueProperty(String name) {
> return getDataProperty(getValue(), name);
> }
>
> public T getKeyProperty(String name) {
> return getDataProperty(getKey(), name);
> }
>
> private T getDataProperty(Object data, String name) {
> if (data instanceof Struct) {
> Struct struct = (Struct) data;
> return struct.get(name);
> } else {
> Map value = (Map) data;
> return value.get(name);
> }
> }
# Is this a feature you would work on yourself?
Yes
* [ ] I plan to open a pull request for this feature
Beitragsleitfaden
Bewertung
Dieses Issue wurde noch nicht bewertet.