python (12.9k questions)

javascript (9.2k questions)

reactjs (4.7k questions)

java (4.2k questions)

java (4.2k questions)

c# (3.5k questions)

c# (3.5k questions)

html (3.3k questions)

Questions - ksqldb

Does anybody have a KSQL query that counts event in a topic on a per hour basis?

I am new to KSQL and I am trying to get the counts of the events in a topic group per hour. If not I would settle for counting the events in the topic. Then I could change the query to work in a windo...
test-img

Fabio

ksqldb

Votes: 0

Answers: 1

Latest Answer

First create a stream over the topic: CREATE STREAM my_stream (NAME VARCHAR, MESSAGE VARCHAR) WITH (KAFKA_TOPIC='my_topic', FORMAT='JSON'); Then use a TUMBLING window aggregation and a dummy GROUP ...
test-img

Robin Moffatt

How can I config ksqldb to understand binary proto-buffer message in kafka?

I want to use ksqldb to do some query on the streamed data encoded in proto-buffer format. But I don't have a clue how to achieve it. What if the binary message data is plain c struct, how to decode t...
test-img

Xiaoyong Guo

ksqldb

Votes: 0

Answers: 1

Latest Answer

ksqlDB supports Protobuf that's been serialised using the Schema Registry format. To specify your data as protobuf use FORMAT='PROTOBUF' e.g. CREATE STREAM my_stream WITH (KAFKA_TOPIC='my_topic', ...
test-img

Robin Moffatt

KSQL+Streams+Kubernetes Timeout while waiting for command topic consumer to process command

I'm new in k8s and KSQL, so I would be appreciate for any suggestion. We have an 1 KSQL Server as ETL,3 Kafka,3 Zookeeper and 1 Kafka-Connect Pods in k8s. While creating new stream we receive an error...
test-img

r_k

kubernetes

etl

apache-kafka-streams

confluent-platform

ksqldb

Votes: 0

Answers: 0

Kafka/KsqlDb : Why is PRIMARY KEY appending chars?

I intend to create a TABLE called WEB_TICKETS where the PRIMARY KEY is equal to the key->ID value. For some reason, when I run the CREATE TABLE instruction the PRIMARY KEY value is appended with th...
test-img

malexanders

apache-kafka

primary-key

ksqldb

apache-kafka

primary-key

ksqldb

Votes: 0

Answers: 1

Latest Answer

It appears as though I wasn't properly setting the KEY FORMAT. The following command produces the expected result. CREATE TABLE web_tickets_test_2 ( id_pk VARCHAR PRIMARY KEY ) WITH (KAFKA_TOPIC =...
test-img

malexanders

Posts

Questions

Blogs

Jobs