ksqldb-users

Contact owners and managers

1–30 of 129

Welcome to the ksql-users google group!

This group is for any user questions, problems or suggestions about KSQL https://github.com/confluentinc/ksql

0 selected

Apr 2

Reading data from a column in a struct and add column with this value in another struct in the avro message

Hi, I have an avro message with structure like this. before:{ a:'value', b:'value' }

unread,

Reading data from a column in a struct and add column with this value in another struct in the avro message

Hi, I have an avro message with structure like this. before:{ a:'value', b:'value' }

Apr 2

Mar 5

Comparing ksqlDB with Timeplus Proton

https://www.timeplus.com/post/proton-ksqldb-alternative A deep dive from CTO of Timeplus. ksqlDB is

unread,

Comparing ksqlDB with Timeplus Proton

https://www.timeplus.com/post/proton-ksqldb-alternative A deep dive from CTO of Timeplus. ksqlDB is

Mar 5

Feb 23

What is expected to the join window when ksql cluster is restarted?

It seems that when we perform a rolling restart of our ksql cluster in k8s, messages don't make

unread,

What is expected to the join window when ksql cluster is restarted?

It seems that when we perform a rolling restart of our ksql cluster in k8s, messages don't make

Feb 23

10/18/23

Maximum number of push queries exceeded

Hello! We are running our kafka and ksqldb on our servers and we came across an issue with a maximum

unread,

Maximum number of push queries exceeded

Hello! We are running our kafka and ksqldb on our servers and we came across an issue with a maximum

10/18/23

Anup Tiwari, Sergio Pena Anaya7

9/13/23

Use Case : At any point of time last N hours of aggregated data needed

Just to update the community that I have already developed a close workaround of this use case with

unread,

Use Case : At any point of time last N hours of aggregated data needed

Just to update the community that I have already developed a close workaround of this use case with

9/13/23

8/15/23

DROP STREAM parse error

I have solved my problem, it was encoding issue. The file had UTF-8 BOM encoding, which adds

unread,

DROP STREAM parse error

I have solved my problem, it was encoding issue. The file had UTF-8 BOM encoding, which adds

8/15/23

8/10/23

Error while creating ksql stream and table

Hi team, I've just started working on KsqlDB for real-time streaming. I'm using Opensource

unread,

Error while creating ksql stream and table

Hi team, I've just started working on KsqlDB for real-time streaming. I'm using Opensource

8/10/23

Ratheesh Ramachandran, Niels Berglund2

7/11/23

ROWTIME criteria and timestamp index

Hi! See following link: Event-time semantics using ksqlDB (confluent.io) Short summary, if you in

unread,

ROWTIME criteria and timestamp index

Hi! See following link: Event-time semantics using ksqlDB (confluent.io) Short summary, if you in

7/11/23

6/15/23

push a query on a materialized table runs forever

Hi There, I am running a push a query on a materialized table to get all the records and it's

unread,

push a query on a materialized table runs forever

Hi There, I am running a push a query on a materialized table to get all the records and it's

6/15/23

3/1/23

ksqlDB migrations tool HTTP2 Error when trying to apply migrations via ksqldb-cli docker image

Hi there, I am trying to use ksqlDB migrations via a Github Actions file like so: https://github.com/

unread,

ksqlDB migrations tool HTTP2 Error when trying to apply migrations via ksqldb-cli docker image

Hi there, I am trying to use ksqlDB migrations via a Github Actions file like so: https://github.com/

3/1/23

Derek Troy-West

2/21/23

Community License Query

Hello, We are integrating a ksqlDB UI into our product (https://kpow.io). Can we use the Confluent

unread,

Community License Query

Hello, We are integrating a ksqlDB UI into our product (https://kpow.io). Can we use the Confluent

2/21/23

Muhammed Rahiz, Matthias J. Sax2

2/16/23

Joins are unsuccessful

Its hard to say. Did you try increasing `streams.max.task.idle.ms` config? -Matthias On 2/16/23 1:59

unread,

Joins are unsuccessful

Its hard to say. Did you try increasing `streams.max.task.idle.ms` config? -Matthias On 2/16/23 1:59

2/16/23

1/11/23

KSQL appends _0 to name of oneof field

I have the following protobuf definition in the schema registry: message Event { oneof tx_details {

unread,

KSQL appends _0 to name of oneof field

I have the following protobuf definition in the schema registry: message Event { oneof tx_details {

1/11/23

12/6/22

Ksqldb batched query not working in quarkus

Hello there, I'm trying to use ksqldb in a kafka reactive microservice with avro records. First

unread,

Ksqldb batched query not working in quarkus

Hello there, I'm trying to use ksqldb in a kafka reactive microservice with avro records. First

12/6/22

11/29/22

Best practices in migrating schema?

Hello, Our use case involves modifying the schema every so often. For example, fields may be added to

unread,

Best practices in migrating schema?

Hello, Our use case involves modifying the schema every so often. For example, fields may be added to

11/29/22

Jacek Laskowski, Sergio Pena Anaya7

10/5/22

What's the latest version? v0.27.2?

Hi Sergio, Got the issue fixed just today! It was my local m2 repo that was the issue so after I

unread,

What's the latest version? v0.27.2?

Hi Sergio, Got the issue fixed just today! It was my local m2 repo that was the issue so after I

10/5/22

9/20/22

Request review for new KLIP

Hi, ksqldb team. I proposed KLIP-67 the other day, which proposes to make internal topic prefix

unread,

Request review for new KLIP

Hi, ksqldb team. I proposed KLIP-67 the other day, which proposes to make internal topic prefix

9/20/22

6/27/22

Running different KSQL queries based on message type

Is there a way to create a Push query that can dynamically run different SQL based on incoming

unread,

Running different KSQL queries based on message type

Is there a way to create a Push query that can dynamically run different SQL based on incoming

6/27/22

6/1/22

[confluent ksqlDB 7.1.1] : Pull Query Not responding and sometime responding very late

Team, I can see a similar issue in ksqlDB 0.25.1. I don't know what is happening and why it is

unread,

[confluent ksqlDB 7.1.1] : Pull Query Not responding and sometime responding very late

Team, I can see a similar issue in ksqlDB 0.25.1. I don't know what is happening and why it is

6/1/22

Rohit Tanwar, … db3

5/27/22

KsqlDb Cluster is not working

you need to make sure that this env variable/configuration is set: ksql.heartbeat.enable = true

unread,

KsqlDb Cluster is not working

you need to make sure that this env variable/configuration is set: ksql.heartbeat.enable = true

5/27/22

S.AliReza Golmohammadi, Matthias J. Sax2

5/3/22

restore materialized table after ksql cluster restart

Using stateful sets can help. Another alternative (you can also combine both) is to enable standby

unread,

restore materialized table after ksql cluster restart

Using stateful sets can help. Another alternative (you can also combine both) is to enable standby

5/3/22

3/24/22

Hi Team, My requirement is to query the data from Kafka topic with given unique string. Can I use

unread,

Hi Team, My requirement is to query the data from Kafka topic with given unique string. Can I use

3/24/22

Guillermo Cruz, Rupesh alasundkar2

3/14/22

Cluster Failure when on Multiple Bare Metal machines running docker.

Did you solve this error? I am also facing issue while configuring cluster/ On Monday, June 15, 2020

unread,

Cluster Failure when on Multiple Bare Metal machines running docker.

Did you solve this error? I am also facing issue while configuring cluster/ On Monday, June 15, 2020

3/14/22

Jacek Laskowski, Natea Eshetu Beshada10

2/9/22

How to build 0.22.0?

Hi Jacek, Thank you for your patience as we transitioned our release pipeline. You should now be able

unread,

How to build 0.22.0?

Hi Jacek, Thank you for your patience as we transitioned our release pipeline. You should now be able

2/9/22

larry Bilo, Michael Drogalis2

2/2/22

creating struct keys for sink streams

Hey Larry, welcome to ksqlDB! Two useful tips. 1. Using the `PARTITION BY` (for a stream) or `GROUP

unread,

creating struct keys for sink streams

Hey Larry, welcome to ksqlDB! Two useful tips. 1. Using the `PARTITION BY` (for a stream) or `GROUP

2/2/22

Jacek Laskowski, Sergio Pena Anaya3

1/4/22

Why is DropType not in io.confluent.ksql.parser.tree package?

Perhaps a mistake when adding the class. I don't see why it shouldn't belong to io.confluent.

unread,

Why is DropType not in io.confluent.ksql.parser.tree package?

Perhaps a mistake when adding the class. I don't see why it shouldn't belong to io.confluent.

1/4/22

12/27/21

KSQLDB installation

Hi Guys, is KSQL community supported in vm based installation? or is that only ksql containers are

unread,

KSQLDB installation

Hi Guys, is KSQL community supported in vm based installation? or is that only ksql containers are

12/27/21

Jacek Laskowski, Natea Eshetu Beshada2

12/17/21

0.23.1 released? With v0.23.1-rc9 tag?

Hi Jacek, No you are not missing anything and yes the v0.23.1-rc9 tag with the sources is the latest

unread,

0.23.1 released? With v0.23.1-rc9 tag?

Hi Jacek, No you are not missing anything and yes the v0.23.1-rc9 tag with the sources is the latest

12/17/21

11/29/21

ksqlDB 0.21 || Drop table delete topic command frequently going in "Executing statement" state

Hi Team, Can someone check this and share any pointers ? Regards, Anup Tiwari On Thu, Nov 25, 2021 at

unread,

ksqlDB 0.21 || Drop table delete topic command frequently going in "Executing statement" state

Hi Team, Can someone check this and share any pointers ? Regards, Anup Tiwari On Thu, Nov 25, 2021 at

11/29/21

10/26/21

Load Test ksqlDB || Pull Queries not responding

Team, I have opened an issue for this since I am getting this error very frequently. Let me know if I

unread,

Load Test ksqlDB || Pull Queries not responding

Team, I have opened an issue for this since I am getting this error very frequently. Let me know if I

10/26/21

Search

Clear search

Close search

Google apps

Main menu