KSQL Error when testing set up - Error issuing POST to KSQL server
1,939 views
Skip to first unread message
Jonathan Bowker
Apr 18, 2018, 11:04:20 AM4/18/18
to Confluent Platform
I am getting this error when creating ksql queries:
CREATE TABLE users (registertime BIGINT, gender VARCHAR, regionid VARCHAR, \
> userid VARCHAR, \interests array<VARCHAR>, contact_info map<VARCHAR, VARCHAR>) \
> WITH (KAFKA_TOPIC='users', VALUE_FORMAT='JSON', KEY = 'userid');
Error issuing POST to KSQL server
Caused by: java.net.SocketException: Connection reset
Caused by: Connection reset
Does anybody have any ideas what I might be doing wrong. I am running on a Macbook pro uisng High Sierra
Thanks
CREATE TABLE users (registertime BIGINT, gender VARCHAR, regionid VARCHAR, \
> userid VARCHAR, \interests array<VARCHAR>, contact_info map<VARCHAR, VARCHAR>) \
> WITH (KAFKA_TOPIC='users', VALUE_FORMAT='JSON', KEY = 'userid');
Error issuing POST to KSQL server
Caused by: java.net.SocketException: Connection reset
Caused by: Connection reset
Does anybody have any ideas what I might be doing wrong. I am running on a Macbook pro uisng High Sierra
Thanks
Robin Moffatt
Apr 18, 2018, 11:08:28 AM4/18/18
to confluent...@googlegroups.com
What version of KSQL/Confluent Platform are you running?
--
You received this message because you are subscribed to the Google Groups "Confluent Platform" group.
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platform+unsub...@googlegroups.com.
To post to this group, send email to confluent-platform@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/c9d66803-a961-4101-ad5a-1f0a59330d7f%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
Jonathan Bowker
Apr 18, 2018, 11:24:05 AM4/18/18
to confluent...@googlegroups.com
Thanks for you response, I am using confluent-4.1.0
-JB
Jonathan Bowker
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platf...@googlegroups.com.
To post to this group, send email to confluent...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/CA%2BJsER0Lmo4Kh2XpSA5G45vb8tXztTaWvPpc9RnKAooD9xmsUg%40mail.gmail.com.
Jonathan Bowker
Apr 18, 2018, 11:24:52 AM4/18/18
to Confluent Platform
Thanks for your response, I am using confluent-4.1.0
On Wednesday, 18 April 2018 16:08:28 UTC+1, Robin Moffatt wrote:
What version of KSQL/Confluent Platform are you running?
On 18 April 2018 at 16:04, Jonathan Bowker <j.b.b...@gmail.com> wrote:
I am getting this error when creating ksql queries:
CREATE TABLE users (registertime BIGINT, gender VARCHAR, regionid VARCHAR, \
> userid VARCHAR, \interests array<VARCHAR>, contact_info map<VARCHAR, VARCHAR>) \
> WITH (KAFKA_TOPIC='users', VALUE_FORMAT='JSON', KEY = 'userid');
Error issuing POST to KSQL server
Caused by: java.net.SocketException: Connection reset
Caused by: Connection reset
Does anybody have any ideas what I might be doing wrong. I am running on a Macbook pro uisng High Sierra
Thanks
--
You received this message because you are subscribed to the Google Groups "Confluent Platform" group.
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platform+unsub...@googlegroups.com.
To post to this group, send email to confluent...@googlegroups.com.
Jonathan Bowker
Apr 18, 2018, 11:36:05 AM4/18/18
to Confluent Platform
Here is the string:
**************** WARNING ******************
Remote server address may not be valid:
Error issuing GET to KSQL server
**************** WARNING ******************
Remote server address may not be valid:
Error issuing GET to KSQL server
Caused by: java.net.SocketException: Connection reset
Caused by: Connection reset
*******************************************
===========================================
= _ __ _____ ____ _ =
= | |/ // ____|/ __ \| | =
= | ' /| (___ | | | | | =
= | < \___ \| | | | | =
= | . \ ____) | |__| | |____ =
= |_|\_\_____/ \___\_\______| =
= =
= Streaming SQL Engine for Apache Kafka® =
===========================================
Copyright 2017 Confluent Inc.
CLI v4.1.0, Server v<unknown> located at http://localhost:8088
Having trouble? Type 'help' (case-insensitive) for a rundown of how things work!
ksql> ksql> CREATE STREAM pageviews (viewtime BIGINT, userid VARCHAR, pageid VARCHAR) \
> WITH (KAFKA_TOPIC='pageviews', VALUE_FORMAT='DELIMITED');
line 1:1: mismatched input 'ksql' expecting {<EOF>, '(', 'SELECT', 'VALUES', 'CREATE', 'REGISTER', 'TABLE', 'DESCRIBE', 'PRINT', 'EXPLAIN', 'SHOW', 'LIST', 'TERMINATE', 'LOAD', 'DROP', 'SET', 'EXPORT', 'UNSET', 'RUN'}
Caused by: line 1:1: mismatched input 'ksql' expecting {<EOF>, '(', 'SELECT', 'VALUES', 'CREATE', 'REGISTER', 'TABLE', 'DESCRIBE', 'PRINT', 'EXPLAIN', 'SHOW', 'LIST', 'TERMINATE', 'LOAD', 'DROP', 'SET', 'EXPORT', 'UNSET', 'RUN'}
Caused by: null
ksql> CREATE STREAM pageviews (viewtime BIGINT, userid VARCHAR, pageid VARCHAR) \
> WITH (KAFKA_TOPIC='pageviews', VALUE_FORMAT='DELIMITED');
===========================================
= _ __ _____ ____ _ =
= | |/ // ____|/ __ \| | =
= | ' /| (___ | | | | | =
= | < \___ \| | | | | =
= | . \ ____) | |__| | |____ =
= |_|\_\_____/ \___\_\______| =
= =
= Streaming SQL Engine for Apache Kafka® =
===========================================
Copyright 2017 Confluent Inc.
CLI v4.1.0, Server v<unknown> located at http://localhost:8088
Having trouble? Type 'help' (case-insensitive) for a rundown of how things work!
ksql> ksql> CREATE STREAM pageviews (viewtime BIGINT, userid VARCHAR, pageid VARCHAR) \
> WITH (KAFKA_TOPIC='pageviews', VALUE_FORMAT='DELIMITED');
line 1:1: mismatched input 'ksql' expecting {<EOF>, '(', 'SELECT', 'VALUES', 'CREATE', 'REGISTER', 'TABLE', 'DESCRIBE', 'PRINT', 'EXPLAIN', 'SHOW', 'LIST', 'TERMINATE', 'LOAD', 'DROP', 'SET', 'EXPORT', 'UNSET', 'RUN'}
Caused by: line 1:1: mismatched input 'ksql' expecting {<EOF>, '(', 'SELECT', 'VALUES', 'CREATE', 'REGISTER', 'TABLE', 'DESCRIBE', 'PRINT', 'EXPLAIN', 'SHOW', 'LIST', 'TERMINATE', 'LOAD', 'DROP', 'SET', 'EXPORT', 'UNSET', 'RUN'}
Caused by: null
ksql> CREATE STREAM pageviews (viewtime BIGINT, userid VARCHAR, pageid VARCHAR) \
> WITH (KAFKA_TOPIC='pageviews', VALUE_FORMAT='DELIMITED');
Error issuing POST to KSQL server
Caused by: java.net.SocketException: Connection reset
Caused by: Connection reset
ksql> /bin/ksql-datagen quickstart=pageviews format=delimited topic=pageviews maxInterval=100
line 1:1: mismatched input '/' expecting {<EOF>, '(', 'SELECT', 'VALUES', 'CREATE', 'REGISTER', 'TABLE', 'DESCRIBE', 'PRINT', 'EXPLAIN', 'SHOW', 'LIST', 'TERMINATE', 'LOAD', 'DROP', 'SET', 'EXPORT', 'UNSET', 'RUN'}
Caused by: line 1:1: mismatched input '/' expecting {<EOF>, '(', 'SELECT', 'VALUES', 'CREATE', 'REGISTER', 'TABLE', 'DESCRIBE', 'PRINT', 'EXPLAIN', 'SHOW', 'LIST', 'TERMINATE', 'LOAD', 'DROP', 'SET', 'EXPORT', 'UNSET', 'RUN'}
Caused by: null
ksql> CREATE STREAM pageviews (viewtime BIGINT, userid VARCHAR, pageid VARCHAR) WITH (KAFKA_TOPIC='pageviews', VALUE_FORMAT='DELIMITED');
line 1:1: mismatched input '/' expecting {<EOF>, '(', 'SELECT', 'VALUES', 'CREATE', 'REGISTER', 'TABLE', 'DESCRIBE', 'PRINT', 'EXPLAIN', 'SHOW', 'LIST', 'TERMINATE', 'LOAD', 'DROP', 'SET', 'EXPORT', 'UNSET', 'RUN'}
Caused by: line 1:1: mismatched input '/' expecting {<EOF>, '(', 'SELECT', 'VALUES', 'CREATE', 'REGISTER', 'TABLE', 'DESCRIBE', 'PRINT', 'EXPLAIN', 'SHOW', 'LIST', 'TERMINATE', 'LOAD', 'DROP', 'SET', 'EXPORT', 'UNSET', 'RUN'}
Caused by: null
ksql> CREATE STREAM pageviews (viewtime BIGINT, userid VARCHAR, pageid VARCHAR) WITH (KAFKA_TOPIC='pageviews', VALUE_FORMAT='DELIMITED');
Error issuing POST to KSQL server
Caused by: java.net.SocketException: Connection reset
Caused by: Connection reset
ksql> CREATE STREAM pageviews (viewtime BIGINT, userid VARCHAR, pageid VARCHAR) WITH (KAFKA_TOPIC='pageviews', VALUE_FORMAT='DELIMITED');
Error issuing POST to KSQL server
Caused by: java.net.SocketException: Connection reset
Caused by: Connection reset
ksql> CREATE STREAM pageviews (viewtime BIGINT, userid VARCHAR, pageid VARCHAR) \
> WITH (KAFKA_TOPIC='pageviews', VALUE_FORMAT='DELIMITED');
> WITH (KAFKA_TOPIC='pageviews', VALUE_FORMAT='DELIMITED');
Error issuing POST to KSQL server
Caused by: java.net.SocketException: Connection reset
Caused by: Connection reset
ksql> CREATE STREAM pageviews (viewtime BIGINT, userid VARCHAR, pageid VARCHAR) \
> WITH (KAFKA_TOPIC='pageviews', VALUE_FORMAT='DELIMITED');
> WITH (KAFKA_TOPIC='pageviews', VALUE_FORMAT='DELIMITED');
Error issuing POST to KSQL server
Caused by: java.net.SocketException: Connection reset
Caused by: Connection reset
ksql> CREATE STREAM pageviews (viewtime BIGINT, userid VARCHAR, pageid VARCHAR) \WITH (KAFKA_TOPIC='pageviews', VALUE_FORMAT='DELIMITED');
Error issuing POST to KSQL server
Caused by: java.net.SocketException: Connection reset
Caused by: Connection reset
ksql> CREATE STREAM pageviews (viewtime BIGINT, userid VARCHAR, pageid VARCHAR) \ WITH (KAFKA_TOPIC='pageviews', VALUE_FORMAT='DELIMITED');
Error issuing POST to KSQL server
Caused by: java.net.SocketException: Connection reset
Caused by: Connection reset
ksql> CREATE STREAM pageviews (viewtime BIGINT, userid VARCHAR, pageid VARCHAR) WITH (KAFKA_TOPIC='pageviews', VALUE_FORMAT='DELIMITED');
Error issuing POST to KSQL server
Caused by: java.net.SocketException: Connection reset
Caused by: Connection reset
ksql>
^C
ksql>
^C
ksql>
^C
ksql>
^C
ksql>
^C
ksql> exit
Exiting KSQL.
JBB:confluent-4.1.0 jonathanbowker$ /Users/jonathanbowker/Servers/confluent-4.1.0/bin/ksql
**************** WARNING ******************
Remote server address may not be valid:
Error issuing GET to KSQL server
^C
ksql>
^C
ksql>
^C
ksql>
^C
ksql>
^C
ksql> exit
Exiting KSQL.
JBB:confluent-4.1.0 jonathanbowker$ /Users/jonathanbowker/Servers/confluent-4.1.0/bin/ksql
**************** WARNING ******************
Remote server address may not be valid:
Error issuing GET to KSQL server
Caused by: java.net.SocketException: Connection reset
Caused by: Connection reset
*******************************************
===========================================
= _ __ _____ ____ _ =
= | |/ // ____|/ __ \| | =
= | ' /| (___ | | | | | =
= | < \___ \| | | | | =
= | . \ ____) | |__| | |____ =
= |_|\_\_____/ \___\_\______| =
= =
= Streaming SQL Engine for Apache Kafka® =
===========================================
Copyright 2017 Confluent Inc.
CLI v4.1.0, Server v<unknown> located at http://localhost:8088
Having trouble? Type 'help' (case-insensitive) for a rundown of how things work!
ksql> CREATE STREAM pageviews (viewtime BIGINT, userid VARCHAR, pageid VARCHAR) \ WITH (KAFKA_TOPIC='pageviews', VALUE_FORMAT='DELIMITED');
===========================================
= _ __ _____ ____ _ =
= | |/ // ____|/ __ \| | =
= | ' /| (___ | | | | | =
= | < \___ \| | | | | =
= | . \ ____) | |__| | |____ =
= |_|\_\_____/ \___\_\______| =
= =
= Streaming SQL Engine for Apache Kafka® =
===========================================
Copyright 2017 Confluent Inc.
CLI v4.1.0, Server v<unknown> located at http://localhost:8088
Having trouble? Type 'help' (case-insensitive) for a rundown of how things work!
ksql> CREATE STREAM pageviews (viewtime BIGINT, userid VARCHAR, pageid VARCHAR) \ WITH (KAFKA_TOPIC='pageviews', VALUE_FORMAT='DELIMITED');
Error issuing POST to KSQL server
Caused by: java.net.SocketException: Connection reset
Caused by: Connection reset
ksql> CREATE STREAM pageviews (viewtime BIGINT, userid VARCHAR, pageid VARCHAR) \
line 1:74: missing ';' at '<EOF>'
Caused by: line 1:74: missing ';' at '<EOF>'
ksql> WITH (KAFKA_TOPIC='pageviews', VALUE_FORMAT='DELIMITED');
line 1:1: extraneous input 'WITH' expecting {<EOF>, '(', 'SELECT', 'VALUES', 'CREATE', 'REGISTER', 'TABLE', 'DESCRIBE', 'PRINT', 'EXPLAIN', 'SHOW', 'LIST', 'TERMINATE', 'LOAD', 'DROP', 'SET', 'EXPORT', 'UNSET', 'RUN'}
Caused by: line 1:1: extraneous input 'WITH' expecting {<EOF>, '(', 'SELECT', 'VALUES', 'CREATE', 'REGISTER', 'TABLE', 'DESCRIBE', 'PRINT', 'EXPLAIN', 'SHOW', 'LIST', 'TERMINATE', 'LOAD', 'DROP', 'SET', 'EXPORT', 'UNSET', 'RUN'}
ksql>
ksql> CREATE STREAM pageviews (viewtime BIGINT, userid VARCHAR, pageid VARCHAR);
line 1:74: missing ';' at '<EOF>'
Caused by: line 1:74: missing ';' at '<EOF>'
ksql> WITH (KAFKA_TOPIC='pageviews', VALUE_FORMAT='DELIMITED');
line 1:1: extraneous input 'WITH' expecting {<EOF>, '(', 'SELECT', 'VALUES', 'CREATE', 'REGISTER', 'TABLE', 'DESCRIBE', 'PRINT', 'EXPLAIN', 'SHOW', 'LIST', 'TERMINATE', 'LOAD', 'DROP', 'SET', 'EXPORT', 'UNSET', 'RUN'}
Caused by: line 1:1: extraneous input 'WITH' expecting {<EOF>, '(', 'SELECT', 'VALUES', 'CREATE', 'REGISTER', 'TABLE', 'DESCRIBE', 'PRINT', 'EXPLAIN', 'SHOW', 'LIST', 'TERMINATE', 'LOAD', 'DROP', 'SET', 'EXPORT', 'UNSET', 'RUN'}
ksql>
ksql> CREATE STREAM pageviews (viewtime BIGINT, userid VARCHAR, pageid VARCHAR);
Error issuing POST to KSQL server
Caused by: java.net.SocketException: Connection reset
Caused by: Connection reset
ksql> WITH (KAFKA_TOPIC='pageviews', VALUE_FORMAT='DELIMITED');CREATE STREAM pageviews (viewtime BIGINT, userid VARCHAR, pageid VARCHAR);
line 1:1: extraneous input 'WITH' expecting {<EOF>, '(', 'SELECT', 'VALUES', 'CREATE', 'REGISTER', 'TABLE', 'DESCRIBE', 'PRINT', 'EXPLAIN', 'SHOW', 'LIST', 'TERMINATE', 'LOAD', 'DROP', 'SET', 'EXPORT', 'UNSET', 'RUN'}
Caused by: line 1:1: extraneous input 'WITH' expecting {<EOF>, '(', 'SELECT', 'VALUES', 'CREATE', 'REGISTER', 'TABLE', 'DESCRIBE', 'PRINT', 'EXPLAIN', 'SHOW', 'LIST', 'TERMINATE', 'LOAD', 'DROP', 'SET', 'EXPORT', 'UNSET', 'RUN'}
ksql> WITH (KAFKA_TOPIC='pageviews', VALUE_FORMAT='DELIMITED');
line 1:1: extraneous input 'WITH' expecting {<EOF>, '(', 'SELECT', 'VALUES', 'CREATE', 'REGISTER', 'TABLE', 'DESCRIBE', 'PRINT', 'EXPLAIN', 'SHOW', 'LIST', 'TERMINATE', 'LOAD', 'DROP', 'SET', 'EXPORT', 'UNSET', 'RUN'}
Caused by: line 1:1: extraneous input 'WITH' expecting {<EOF>, '(', 'SELECT', 'VALUES', 'CREATE', 'REGISTER', 'TABLE', 'DESCRIBE', 'PRINT', 'EXPLAIN', 'SHOW', 'LIST', 'TERMINATE', 'LOAD', 'DROP', 'SET', 'EXPORT', 'UNSET', 'RUN'}
ksql>
ksql>
ksql> REATE TABLE users (registertime BIGINT, gender VARCHAR, regionid VARCHAR, \
line 1:1: extraneous input 'WITH' expecting {<EOF>, '(', 'SELECT', 'VALUES', 'CREATE', 'REGISTER', 'TABLE', 'DESCRIBE', 'PRINT', 'EXPLAIN', 'SHOW', 'LIST', 'TERMINATE', 'LOAD', 'DROP', 'SET', 'EXPORT', 'UNSET', 'RUN'}
Caused by: line 1:1: extraneous input 'WITH' expecting {<EOF>, '(', 'SELECT', 'VALUES', 'CREATE', 'REGISTER', 'TABLE', 'DESCRIBE', 'PRINT', 'EXPLAIN', 'SHOW', 'LIST', 'TERMINATE', 'LOAD', 'DROP', 'SET', 'EXPORT', 'UNSET', 'RUN'}
ksql> WITH (KAFKA_TOPIC='pageviews', VALUE_FORMAT='DELIMITED');
line 1:1: extraneous input 'WITH' expecting {<EOF>, '(', 'SELECT', 'VALUES', 'CREATE', 'REGISTER', 'TABLE', 'DESCRIBE', 'PRINT', 'EXPLAIN', 'SHOW', 'LIST', 'TERMINATE', 'LOAD', 'DROP', 'SET', 'EXPORT', 'UNSET', 'RUN'}
Caused by: line 1:1: extraneous input 'WITH' expecting {<EOF>, '(', 'SELECT', 'VALUES', 'CREATE', 'REGISTER', 'TABLE', 'DESCRIBE', 'PRINT', 'EXPLAIN', 'SHOW', 'LIST', 'TERMINATE', 'LOAD', 'DROP', 'SET', 'EXPORT', 'UNSET', 'RUN'}
ksql>
ksql>
ksql> REATE TABLE users (registertime BIGINT, gender VARCHAR, regionid VARCHAR, \
> userid VARCHAR, \interests array<VARCHAR>, contact_info map<VARCHAR, VARCHAR>) \
> WITH (KAFKA_TOPIC='users', VALUE_FORMAT='JSON', KEY = 'userid');
line 1:1: extraneous input 'REATE' expecting {<EOF>, '(', 'SELECT', 'VALUES', 'CREATE', 'REGISTER', 'TABLE', 'DESCRIBE', 'PRINT', 'EXPLAIN', 'SHOW', 'LIST', 'TERMINATE', 'LOAD', 'DROP', 'SET', 'EXPORT', 'UNSET', 'RUN'}
Caused by: line 1:1: extraneous input 'REATE' expecting {<EOF>, '(', 'SELECT', 'VALUES', 'CREATE', 'REGISTER', 'TABLE', 'DESCRIBE', 'PRINT', 'EXPLAIN', 'SHOW', 'LIST', 'TERMINATE', 'LOAD', 'DROP', 'SET', 'EXPORT', 'UNSET', 'RUN'}
ksql> CREATE TABLE users (registertime BIGINT, gender VARCHAR, regionid VARCHAR, \
Caused by: line 1:1: extraneous input 'REATE' expecting {<EOF>, '(', 'SELECT', 'VALUES', 'CREATE', 'REGISTER', 'TABLE', 'DESCRIBE', 'PRINT', 'EXPLAIN', 'SHOW', 'LIST', 'TERMINATE', 'LOAD', 'DROP', 'SET', 'EXPORT', 'UNSET', 'RUN'}
ksql> CREATE TABLE users (registertime BIGINT, gender VARCHAR, regionid VARCHAR, \
> userid VARCHAR, \interests array<VARCHAR>, contact_info map<VARCHAR, VARCHAR>) \
> WITH (KAFKA_TOPIC='users', VALUE_FORMAT='JSON', KEY = 'userid');
Error issuing POST to KSQL server
Caused by: java.net.SocketException: Connection reset
Caused by: Connection reset
ksql> CREATE STREAM pageviews (viewtime BIGINT, userid VARCHAR, pageid VARCHAR) \
> WITH (KAFKA_TOPIC='pageviews', VALUE_FORMAT='DELIMITED');
> WITH (KAFKA_TOPIC='pageviews', VALUE_FORMAT='DELIMITED');
Error issuing POST to KSQL server
Caused by: java.net.SocketException: Connection reset
Caused by: Connection reset
ksql>
ro...@confluent.io
Apr 18, 2018, 12:34:03 PM4/18/18
to Confluent Platform
Looks like the KSQL Server isn't running (long shot guess : possibly you have something else running on 8088, which stopped ksql server starting and which is giving you the Connection reset errors when KSQL tries to connect to it).
You should get something like:
Are you using Confluent CLI? Can you paste here the output of
confluent status
You should get something like:
Robin@asgard02 ~> confluent statuscontrol-center is [UP]ksql-server is [UP]connect is [UP]kafka-rest is [UP]schema-registry is [UP]kafka is [UP]zookeeper is [UP]Robin@asgard02 ~>
Mob: +44 (0) 755 204 5721
Skype: JonathanBowker
Twitter: @jonathanbowker
On 18 Apr 2018, at 4:07 pm, Robin Moffatt <ro...@confluent.io> wrote:
What version of KSQL/Confluent Platform are you running?
On 18 April 2018 at 16:04, Jonathan Bowker <j.b.b...@gmail.com> wrote:
I am getting this error when creating ksql queries:
CREATE TABLE users (registertime BIGINT, gender VARCHAR, regionid VARCHAR, \
> userid VARCHAR, \interests array<VARCHAR>, contact_info map<VARCHAR, VARCHAR>) \
> WITH (KAFKA_TOPIC='users', VALUE_FORMAT='JSON', KEY = 'userid');
Error issuing POST to KSQL server
Caused by: java.net.SocketException: Connection reset
Caused by: Connection reset
Does anybody have any ideas what I might be doing wrong. I am running on a Macbook pro uisng High Sierra
Thanks
--
You received this message because you are subscribed to the Google Groups "Confluent Platform" group.
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platform+unsub...@googlegroups.com.
To post to this group, send email to confluent...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/c9d66803-a961-4101-ad5a-1f0a59330d7f%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
--
You received this message because you are subscribed to the Google Groups "Confluent Platform" group.
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platform+unsub...@googlegroups.com.
To post to this group, send email to confluent...@googlegroups.com.
Jonathan Bowker
Apr 18, 2018, 12:54:30 PM4/18/18
to confluent...@googlegroups.com
This is what I get:
JBB:confluent-4.1.0 jonathanbowker$ confluent status
ksql-server is [UP]
connect is [UP]
kafka-rest is [UP]
schema-registry is [UP]
kafka is [UP]
zookeeper is [UP]
JBB:confluent-4.1.0 jonathanbowker$
Mob: +44 (0) 755 204 5721
Skype: JonathanBowker
Twitter: @jonathanbowker
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platf...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/458f3812-1655-48e4-bcb2-6535ee2817c5%40googlegroups.com.
hoj...@confluent.io
Apr 18, 2018, 2:37:41 PM4/18/18
to Confluent Platform
The error message indicates the connection to ksql server is not established. Can you restart both Confluent Platform and KSQL CLI and try again.
On Wednesday, April 18, 2018 at 9:54:30 AM UTC-7, Jonathan Bowker wrote:
This is what I get:JBB:confluent-4.1.0 jonathanbowker$ confluent statusksql-server is [UP]connect is [UP]kafka-rest is [UP]schema-registry is [UP]kafka is [UP]zookeeper is [UP]JBB:confluent-4.1.0 jonathanbowker$
-JBJonathan Bowker
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platform+unsubscri...@googlegroups.com.
To post to this group, send email to confluent...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/c9d66803-a961-4101-ad5a-1f0a59330d7f%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
--
You received this message because you are subscribed to the Google Groups "Confluent Platform" group.
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platform+unsubscri...@googlegroups.com.
To post to this group, send email to confluent...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/CA%2BJsER0Lmo4Kh2XpSA5G45vb8tXztTaWvPpc9RnKAooD9xmsUg%40mail.gmail.com.
For more options, visit https://groups.google.com/d/optout.
--
You received this message because you are subscribed to the Google Groups "Confluent Platform" group.
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platform+unsub...@googlegroups.com.
To post to this group, send email to confluent...@googlegroups.com.
Jonathan Bowker
Apr 18, 2018, 2:57:37 PM4/18/18
to confluent...@googlegroups.com, hoj...@confluent.io
Hi Hojjat,
I have rebooted and restarted confluent and get he this message:
ksql> CREATE STREAM pageviews (viewtime BIGINT, userid VARCHAR, pageid VARCHAR) WITH (KAFKA_TOPIC='pageviews', VALUE_FORMAT='DELIMITED');
Error issuing POST to KSQL server
Caused by: java.net.SocketException: Connection reset
Caused by: Connection reset
ksql>
Please see attached screen shots.
I did have a previous version running which I deleted before installing the latest version, is it possible that is causing some sort of corruption?
Many thanks,
Jonathan
Mob: +44 (0) 755 204 5721
Skype: JonathanBowker
Twitter: @jonathanbowker
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platf...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/037d5afb-aad8-4865-83c1-5fdfa2f503bd%40googlegroups.com.
Hojjat Jafarpour
Apr 18, 2018, 3:43:34 PM4/18/18
to Jonathan Bowker, confluent...@googlegroups.com
To me it seems like the KSQL server is not up. You tried 'confluent status' as Robin said and it shows KSQL server is up.
Can you try the following commands in CLI too:
'show topics;'
`show streams;'
Also make sure that the server is running on 8088 port, if not you need to tell cli the correct port to connect to.
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/458f3812-1655-48e4-bcb2-6535ee2817c5%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
--
You received this message because you are subscribed to the Google Groups "Confluent Platform" group.
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platform+unsub...@googlegroups.com.
Andy Coates
Apr 18, 2018, 6:20:48 PM4/18/18
to Confluent Platform
Hi Jonathan,
The error you're seeing when starting KSQL:
**************** WARNING ******************
Remote server address may not be valid:
Error issuing GET to KSQL server
Caused by: java.net.SocketException: Connection reset
Caused by: Connection reset
*******************************************
Remote server address may not be valid:
Error issuing GET to KSQL server
Caused by: java.net.SocketException: Connection reset
Caused by: Connection reset
Suggests the CLI is not able to connect to the KSQL server. As others have suggested, you should check that the KSQL server is indeed listening for connections on the expected port. In case you're not sure how to do this, I've added some steps below.
The following command should output information about what process is listening on port 8088:
netstat -anv | egrep -w .*8088.*LISTEN
You should see an output similar to:
tcp4 0 0 *.8088 *.* LISTEN 131072 131072 46314 0Where '46314' is the PID of the process listening on port 8088.
If you then run the following, (with the correct pid), to get information on the process listening on that port:
ps -wwwp 46314
If all is well, then this should spool off the command line of the KsqlServer process, which will likely end with something similar to:
io.confluent.ksql.rest.server.KsqlServerMain ./config/ksql-server.properties
If this is not the case, try stopping what ever is running on port 8088 and restart the confluent platform. (And let us know as this would be a bug in the status reporting!).
If this is the case, then you may want to check the KSQL server logs for some clues by running:
confluent log ksql-server
Hope this helps,
Andy
On Wednesday, April 18, 2018 at 7:57:37 PM UTC+1, Jonathan Bowker wrote:
Hi Hojjat,I have rebooted and restarted confluent and get he this message:ksql> CREATE STREAM pageviews (viewtime BIGINT, userid VARCHAR, pageid VARCHAR) WITH (KAFKA_TOPIC='pageviews', VALUE_FORMAT='DELIMITED');Error issuing POST to KSQL serverCaused by: java.net.SocketException: Connection resetCaused by: Connection resetksql>Please see attached screen shots.I did have a previous version running which I deleted before installing the latest version, is it possible that is causing some sort of corruption?Many thanks,Jonathan
-JBJonathan Bowker
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/458f3812-1655-48e4-bcb2-6535ee2817c5%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
--
You received this message because you are subscribed to the Google Groups "Confluent Platform" group.
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platform+unsub...@googlegroups.com.
To post to this group, send email to confluent...@googlegroups.com.
Jonathan Bowker
Apr 19, 2018, 1:17:39 AM4/19/18
to confluent...@googlegroups.com, an...@confluent.io
Hi Andy,
Thanks for your help. The culprit was InfluxDB which by default uses the 8088.
On mac I had to did the following
$ netstat -anv | egrep -w .*8088.*LISTEN
tcp4 0 0 127.0.0.1.8088 *.* LISTEN 131072 131072 442 0
$ lsof -t -i tcp:8088 | xargs kill
All good and thanks for your your help.
Mob: +44 (0) 755 204 5721
Skype: JonathanBowker
Twitter: @jonathanbowker
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platf...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/9ebeba5a-cb8e-440c-a778-67f27cf52489%40googlegroups.com.
Andy Coates
Apr 19, 2018, 6:33:59 AM4/19/18
to Confluent Platform
Great to hear you're up and running!
I've created the follow to track the fact that `confluent status` is incorrectly showing that `ksql-server` is healthy, when it really isn't.
Happy KSQL'ing ;)
Andy
On Thursday, April 19, 2018 at 6:17:39 AM UTC+1, Jonathan Bowker wrote:
Hi Andy,Thanks for your help. The culprit was InfluxDB which by default uses the 8088.On mac I had to did the following
$ netstat -anv | egrep -w .*8088.*LISTENtcp4 0 0 127.0.0.1.8088 *.* LISTEN 131072 131072 442 0$ lsof -t -i tcp:8088 | xargs killAll good and thanks for your your help.
-JBJonathan Bowker
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/037d5afb-aad8-4865-83c1-5fdfa2f503bd%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
--
You received this message because you are subscribed to the Google Groups "Confluent Platform" group.
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platform+unsub...@googlegroups.com.
To post to this group, send email to confluent...@googlegroups.com.
Andy Coates
Apr 19, 2018, 6:34:30 AM4/19/18
to Confluent Platform
And again, but this time with the link!
You received this message because you are subscribed to the Google Groups "Confluent Platform" group.<br style="font-family:Helvetica;font-si
Jonathan Bowker
Apr 19, 2018, 6:35:15 AM4/19/18
to confluent...@googlegroups.com
Thanks Andy, looking forward to exploring
Mob: +44 (0) 755 204 5721
Skype: JonathanBowker
Twitter: @jonathanbowker
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platf...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/9430ac68-e196-4e52-8534-0dce57e0a128%40googlegroups.com.
Student User
Oct 21, 2018, 9:20:49 AM10/21/18
to Confluent Platform
Reply all
Reply to author
Forward
0 new messages