ksql

ksql copied to clipboard

Inactive cluster members and failed select queries

4

I have been experimenting with KSQLDB clusters and i have pull up and down the same docker service a couple of times. Now i am left with a situation where...

dberardo-com

to_json_string to ignore null field

1

**Is your feature request related to a problem? Please describe.** Sometimes `null` field doesn’t add any value. For example we sink kafka topic to postgres `JSONB` column, which will add...

snigdhasjg

### Description The Query property list in the BE was missing some props that this PR is adding. ### Testing done manual testing ### Reviewer checklist - [ ] Ensure...

tolgadur

Stream-Table Inner Join Producing Duplicates record

2

Hi Team, We are using confluent kafka version 6.1.1 We have following setup: 1) Source topic(st): This topic consist of data published from third party kafka producer. We have a...

rkabra1990

ksqlDB CLI crashed - java.io.IOError: java.io.IOException: Error executing 'stty -icrnl -ixon -echo -icanon -iexten min 0 time 1':

4

Pressing Ctrl-C (perhaps a bit too enthusiastically) in ksqlDB CLI with v0.12 on Docker resulted in it crashing out ``` Exception in thread "main" java.io.IOError: java.io.IOException: Error executing 'stty -icrnl...

rmoff

docs: klip-65: ksqldb Node.js client

2

### Description To create a new Node.js client for ksqlDB with the core functionality listed in the [doc](https://docs.ksqldb.io/en/latest/developer-guide/ksqldb-clients/contributing/). Adding more advanced methods including creating materialized view, pulling stream data between...

ggbong734

Source names with '.' (dot) character should be allowed

10

**Describe the bug** The following PR https://github.com/confluentinc/ksql/pull/3695/files#diff-734b7c162230742e416f79fdf85d146dR41-R48 (/cc @agavra) introduces a validation of source name that do not match the allowed Kafka topic names. The "." character is missing in...

Perdjesk

JSON_SR enum gives a struct projection instead of string

1

**Describe the bug** JSON_SR enum gives a struct projection instead of string **To Reproduce** Create topic and register json schema ``` { "$id": "http://example.com/myURI.schema.json", "$schema": "http://json-schema.org/draft-07/schema#", "additionalProperties": false, "description": "Sample...

SamiShaikh

I’m using the VALUE_SCHEMA_ID argument when creating streams, but I noticed that it fails when a field has the following data type ``` "type": [ "null", { "connect.type": "int16", "type":...

kurtis-ley

compression defaults

7

In: [compression.type](https://docs.ksqldb.io/en/latest/reference/server-configuration/#compressiontype) and [ksql.streams.producer.compression.type](https://docs.ksqldb.io/en/latest/reference/server-configuration/#ksqlstreamsproducercompressiontype) it says: _"The default is snappy"_ but the default seems to be 'none' (unless explicitly set in server configuration file or set for the session).

alonpr