Aiven-Open / Aiven-Open/aiven-kafka-connector-framework

Improve ability to manipulate the records in the EvolvingSourceRecord

Offen
#80 0 Kommentare 0 Reaktionen 0 zugewiesene Personen Auf GitHub ansehen
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

Beitragsleitfaden öffnen

Bewertung

Dieses Issue wurde noch nicht bewertet.

Neue Issues direkt in Ihr Postfach

Eine kurze Übersicht über anfängerfreundliche GitHub-Issues.