Terminate running stream - Server v<unknown> located at http://ksqldb-server:8088

[hilwis]

Hi,

Currently i'm facing the error that my ksqldb server doesn't start. When i see the logs using docker logs command, then i found this error

ERROR Exception encountered running command: The statement does not define any columns.
ksqldb-server    | Statement: create stream spr_trans with (kafka_topic ='xxxx.xxxx', value_format='json');. Retrying in 5000 ms

Actually i don't know where did this stream come from, because i'm really sure that i never create that stream.

I'm using docker to build ksqldb over existing kafka. Here's the yml file :

---
version: '2'

services:
  ksqldb-server:
    image: confluentinc/ksqldb-server:0.7.1
    hostname: ksqldb-server
    container_name: ksqldb-server
    ports:
      - "8088:8088"
    environment:
      KSQL_LISTENERS: http://0.0.0.0:8088
      KSQL_BOOTSTRAP_SERVERS: xxxxx.yyyyy.bbb.id:9993
      KSQL_KSQL_LOGGING_PROCESSING_STREAM_AUTO_CREATE: "false"
      KSQL_KSQL_LOGGING_PROCESSING_TOPIC_AUTO_CREATE: "false"

  ksqldb-cli:
    image: confluentinc/ksqldb-cli:0.7.1
    container_name: ksqldb-cli
    depends_on:
      - ksqldb-server
    entrypoint: /bin/sh
    tty: true

Anyone know how can i deal with this problem? Like how can i terminate or kill this stream without using ksqldb cli, because i cannot enter it. Thanks in advance.

[LeonardoBonacci]

Perhaps related to this issue, I encounter the same error running the ksql-test-tool on confluent 5.4.1.

Following this tutorial, https://docs.confluent.io/current/ksql/docs/developer-guide/ksql-testing-tool.html, and changing the first create stream statement to

CREATE STREAM orders WITH (kafka_topic='test_topic', value_format='JSON');

Error:

Test failed: The statement does not define any columns. Statement: CREATE STREAM ORDERS WITH (KAFKA_TOPIC='test_topic', VALUE_FORMAT='JSON');

Related?

[MichaelZhou]

Perhaps related to this issue, I encounter the same error running the ksql-test-tool on confluent 5.4.1.

Following this tutorial, https://docs.confluent.io/current/ksql/docs/developer-guide/ksql-testing-tool.html, and changing the first create stream statement to

CREATE STREAM orders WITH (kafka_topic='test_topic', value_format='JSON');

Error:

Test failed: The statement does not define any columns. Statement: CREATE STREAM ORDERS WITH (KAFKA_TOPIC='test_topic', VALUE_FORMAT='JSON');

Related?

Did you ever resolve your problem with implicit CREATE STREAM statements?