Skip to content

Instantly share code, notes, and snippets.

View matthias-Q's full-sized avatar

Matthias Q matthias-Q

View GitHub Profile
@matthias-Q
matthias-Q / avro_msg_iceberg_upsert.py
Last active July 18, 2025 19:37
KafkaAvroIcebergUpsert
import datetime
from confluent_kafka.schema_registry._sync.schema_registry_client import json
from confluent_kafka.serialization import MessageField, SerializationContext
import pyiceberg
import pyarrow as pa
import pyiceberg.catalog
from pyiceberg.schema import Schema
from pyiceberg.table import Table
from pyiceberg.utils.schema_conversion import AvroSchemaConversion
import tempfile
@matthias-Q
matthias-Q / gist:9a9a5ef5d78355719f7d2ce0a0268185
Created January 15, 2023 10:02
Statuscolumn Autocommand
local augroup = vim.api.nvim_create_augroup
local autocmd = vim.api.nvim_create_autocmd
if _G.StatusColumn then
return
end
_G.StatusColumn = {
handler = {
fold = function()