delta-io/kafka-delta-ingest
A highly efficient daemon for streaming data from Kafka into Delta Lake
RustApache-2.0
Issues
- 0
- 0
Writer ignores the table's "delta.dataSkippingStatsColumns" and "delta.dataSkippingNumIndexedCols"
#189 opened by kpapadatos - 2
Message consumption error: PollExceeded (Local: Maximum application poll interval (max.poll.interval.ms) exceeded)
#191 opened by kpapadatos - 0
Ingest service exited with error DeltaTable { source: Protocol { source: Generic("filed to get tombstones") } }
#193 opened by kpapadatos - 4
Write to multiple delta tables from a single topic
#161 opened by Kikkon - 0
Generated checkpoint files are unexpectedly large and potentially broken
#187 opened by igor-lobanov-maersk - 0
Checkpoint file creation is skipped on restart
#184 opened by morgan-soulie - 0
Build failed on `alpine` because of `rdkafka` `ssl-vendored` instead of `ssl`
#176 opened by thanhminhmr - 0
Dockerfile build failure
#180 opened by giulio1979 - 0
- 1
- 0
Remove direct dynamodb lock interactions
#182 opened by rtyler - 1
- 2
- 7
Documentation to write data to S3
#166 opened by mayanksingh2298 - 3
What is the documentation to use HMS as the catalog with delta lake on S3?
#174 opened by alberttwong - 1
error: future cannot be sent between threads safely -- dead_letters.rs and writer.rs
#167 opened by clairewood - 5
- 1
Put avro support behind an optional feature flag
#163 opened by rtyler - 1
Add CONTRIBUTING.md file
#135 opened by MrPowers - 3
- 3
- 8
Build Error on Windows Machine: Failed to run custom build command for openssl-sys v0.9.61
#42 opened by rajatha-ravish - 4
use of deprecated method `chrono::DateTime::<Tz>::timestamp_nanos`: use `timestamp_nanos_opt()` instead
#156 opened by gdubya - 1
end_at_last_offsets flag is always set
#158 opened by kyrre - 0
Add cron-style "Trigger Once" feature
#75 opened by xianwill - 0
Slack link in the readme is expired
#143 opened by lorenzoc25 - 6
No snapshot or version 0 found
#130 opened by timopetmanson - 2
- 2
unable to run example code: "thread 'main' panicked at 'called `Option::unwrap()` on a `None` value', src\main.rs:91:18"
#146 opened by clairewood - 3
- 2
- 1
- 3
Kafka client collaboration
#122 opened by crepererum - 0
Please change address of arrow rust in DESIGN.md, currently getting error 404
#53 opened by MironAtHome - 1
- 1
Fix the encoding for special cases
#85 opened by mosyp - 1
To connect with aws
#126 opened by binodyadav6119 - 1
Remove some annoying debug messages
#60 opened by mosyp - 0
- 4
- 0
- 1
How to ingest the key?
#117 opened by rymail - 2
no support for gzip?
#89 opened by bbigras - 4
Kafka-connect sink connector
#51 opened by raphaelauv - 1
Keep dead_letters table/client on demand
#93 opened by mosyp - 0
Find a way to run integration tests in parallel
#100 opened by mosyp - 1
Log and send to stats handler the average message size
#62 opened by mosyp - 1
- 0
Handling null partition values on write
#52 opened by houqp