tabular-io / iceberg-kafka-connect

Apache License 2.0
169 stars 31 forks source link

fix-event-decoder-vtt #253

Closed tabmatfournier closed 1 month ago

tabmatfournier commented 1 month ago
│       Trace:  java.lang.NullPointerException: Cannot invoke "java.lang.Long.longValue()" because the return value of "io.tabular.iceberg.connect.events.CommitTablePayload.vtts()" is null                        │
│               at io.tabular.iceberg.connect.channel.EventDecoder.convertPayload(EventDecoder.java:119)                                                                                                            │
│               at io.tabular.iceberg.connect.channel.EventDecoder.convertLegacy(EventDecoder.java:82)                                                                                                              │
│               at io.tabular.iceberg.connect.channel.EventDecoder.decode(EventDecoder.java:77)                                                                                                                     │
│               at io.tabular.iceberg.connect.channel.Channel.lambda$consumeAvailable$2(Channel.java:131)                                                                                                           │
│               at java.base/java.lang.Iterable.forEach(Iterable.java:75)                                                                                                                                           │
│               at io.tabular.iceberg.connect.channel.Channel.consumeAvailable(Channel.java:125)