Hartmut
Hartmut
Idea came up while writing a blog post on the topic -> https://thriving.dev/blog/interactive-queries-with-kafka-streams-cassandra-state-store-part-2 ### Context * The behaviour for large state stores has yet to be tested. * Cassandra fetches...
### Description For event processing logic where you might _read_ specific, or the _most recent data_ often, an in-memory caching layer would be beneficial to improve the performance, lower the...
I want to know how the library / kstreams app behaves throughout the entire lifecycle when interaction with cassandra fails (Exception thrown, ...). Data loss through events being missed/skipped should...
### Precondition `scylladb.offset.storage.table.enable=true` (default) ### Description As a developer I'd like to be able to have multiple connectors consuming the same topic. Currently this is not possible, since the scylla...
fixes https://github.com/scylladb/kafka-connect-scylladb/issues/20
### Description To support "non-flat" value schema, implementing struct support to write -> Scylla as UDT should be possible. ### Limitations - `scylladb.table.manage.enabled` might not be possible, so it would...
Hi, I've been playing, testing and debugging with this lib + simple-printer example, also making use of TableBackedProgressManager + NewPeriodicProgressReporter in particular. For some unexpected behaviour I came up with...
As a consumer of my CDC event stream (Kafka topic), with table cdc enabled and collection types (LIST, SET, MAP) and UDT used, I'd like to receive change data of...
#### Description To allow to tune/customise the behaviour of one's source connector setup, I'd like to also have a config option `poll.interval.ms` in addition to `scylla.query.time.window.size` which defines effectively the...
As a consumer of my CDC event stream (Kafka topic), with table cdc preimages enabled, I'd like to also receive data of the preimage `*_cdc_log` record (`cdc$operation=0`). This would allow...