|
- Do we have a option to get data in KSQL streams from specific time . . .
In ksqlDB you can query from the beginning (SET 'auto offset reset' = 'earliest';) or end of a topic (SET 'auto offset reset' = 'latest';) You cannot currently (0 8 1 CP 5 5) seek to an arbitrary offset What you can do is start from the earliest offset and then use ROWTIME in your predicate to identify messages that match your requirement
- apache kafka streams - KTable vs KSqlDb - Stack Overflow
i'd like to understand difference between KTable and KsqlDb I need two data flows from my "states" topic: Actual snapshot of a state as key-value store; Subscription to events of state data changes; I may created compacted-topic and use KTable as key value store with updates for the 1 case
- Is there a way to consume a Kafka Ksql Push query from . NET
Yes, you can use ksqlDB to do this-- Declare a stream on the source topic -- Because it's JSON you'll need to specify the schema CREATE STREAM my_source (COL1 VARCHAR, COL2 INT) WITH (KAFKA_TOPIC='my_source_topic', VALUE_FORMAT='JSON'); -- Apply the filter to the stream, with the results written -- to a new stream (backed by a new topic) CREATE STREAM target WITH (KAFKA_TOPIC='my_target_topic
- How do I install just the ksqlDB CLI tool on Linux?
Thanks @robin-moffatt Unfortunately I am indeed now solving networking issues The Kafka cluster isn't directly accessible, so in my WSL 2 command line I'm port-forwarding the Kubernetes ksqlDB server port 8088, and trying to connect to that from within Docker (which isn't working yet)
- ksqldb - Confluent Platform - how to properly use ksql-datagen? - Stack . . .
Looks like I may have some form of the issue you have The original docker-compose entry did not have a BOOTSTRAP_SERVER environment variable
- How to filter using ksql with array attribute type
I have a Stream on a topic with schema: --root --name: string --age: integer --accounts: Array --email I would like to select all root elements having accounts with email ='xx' Thanks y
- ksqldb - How to join a KSQL table and a stream on a non row key column . . .
A tombstone is the key, (10), and a null value ksqlDB would then remove the row from its table with key 10, leaving an empty table This is the crux of your problem! First, you'll need to configure the source connector to get both the fence id and fleet id into the key of the messages Next, you'll need to access this in ksqlDB
- How to create KSQL table from a topic with composite key?
Here's an example First, I'll create and populate a test stream ksql> CREATE STREAM TEST (STRINGA VARCHAR, STRINGB VARCHAR, COL3 INT) WITH (KAFKA_TOPIC='TEST
|
|
|