search

timeplus-io / kafka-connect-timeplus

The Timeplus sink connector allows moving data from Kafka to Timeplus Cloud
https://www.confluent.io/hub/timeplus/kafka-timeplus-connector-sink
Apache License 2.0
2 stars 1 forks source link

Proton support #17

Open neodino opened 10 months ago

neodino commented 10 months ago

Hello,

Does this connector support Proton? If so, is there any example you can share. Thanks! Great project

gangtao commented 10 months ago

Hi @neodino , this connector does not support proton for now, but in case you need such feature, we can consider add such support. Can you share with us your use case? usually it take 1 or 2 sprints to add such support.

neodino commented 10 months ago

Thanks for prompt reply. My current setup involves Strimzi operator that I use for Kafka cluster and Kafka Connect (all managed through argocd/gitops). Same setup is used for my sink and source connectors (debezium/camel). Would be great if I can manage all connectors trough this, including proton one.

gangtao commented 10 months ago

@neodino I am working on the PR https://github.com/timeplus-io/kafka-connect-timeplus/pull/18 to add proton support, feel free to comment.

neodino commented 10 months ago

Thanks for update @gangtao. I did build and setup the connector as per document here: https://github.com/timeplus-io/kafka-connect-timeplus/blob/b05c573c5753f2619cd7f028f4fbdc5e1968d6fe/README.md All seems to work ok but getting error bellow. Any idea/tip? Thanks for support.

Proton error 

2024.01.13 04:18:58.914457 [ 272 ] {} <Information> LogManager: Beginning checkpoint log start sns...
2024.01.13 04:18:59.658787 [ 274 ] {} <Information> LogManager: Beginning checkpoint log recovery sns...
2024.01.13 04:19:17.003326 [ 318 ] {} <Information> AsynchronousMetrics: MemoryTracking: was 1.16 GiB, peak 1.86 GiB, free memory in arenas 101.48 MiB, will set to 352.27 MiB (RSS), difference: -836.95 MiB
2024.01.13 04:19:18.003268 [ 318 ] {} <Information> AsynchronousMetrics: MemoryTracking: was -508.03 MiB, peak 1.86 GiB, free memory in arenas 1.18 GiB, will set to 359.09 MiB (RSS), difference: 867.12 MiB
2024.01.13 04:19:21.779563 [ 271 ] {} <Information> LogManager: Beginning flush dirty logs...
2024.01.13 04:19:33.336323 [ 34 ] {95168f0d-aa46-439f-844c-b1e0fe0fcd4e} <Error> executeQuery: Code: 62. DB::Exception: Syntax error: failed at position 1 ('{'): {"columns":[{"name":"raw","type":"string"}],"name":"data_from_kafka"}. Expected one of: Query, Query with output, EXPLAIN, SELECT query, possibly with UNION, list of union elements, SELECT query, subquery, possibly with UNION, SELECT subquery, SELECT query, WITH, SELECT, SUBSCRIBE TO SELECT query, possibly with UNION, SUBSCRIBE, UNSUBSCRIBE FROM SELECT query, possibly with UNION SETTINGS query_id=uuid, UNSUBSCRIBE, RECOVER FROM SELECT query, possibly with UNION SETTINGS query_id=uuid, RECOVER, SHOW CREATE QUOTA query, SHOW CREATE, SHOW CREATE FORMAT SCHEMA query, SHOW, SHOW [TEMPORARY] TABLES|DATABASES|CLUSTERS|CLUSTER 'name' [[NOT] [I]LIKE 'str'] [LIMIT expr], EXISTS or SHOW CREATE query, EXISTS, DESCRIBE FILESYSTEM CACHE query, DESCRIBE, DESC, DESCRIBE query, SHOW PROCESSLIST query, SHOW PROCESSLIST, CREATE STREAM or ATTACH STREAM query, CREATE, ATTACH, CREATE DATABASE query, CREATE VIEW query, CREATE DICTIONARY, CREATE MATERIALIZED VIEW query, ALTER query, ALTER STREAM, ALTER DATABASE, RENAME query, RENAME STREAM, DROP query, DROP, DETACH, TRUNCATE, CHECK TABLE, KILL QUERY query, KILL, OPTIMIZE query, OPTIMIZE TABLE, WATCH query, WATCH, SHOW FORMAT SCHEMAS query, SHOW ACCESS query, SHOW ACCESS, ShowAccessEntitiesQuery, SHOW GRANTS query, SHOW GRANTS, SHOW PRIVILEGES query, SHOW PRIVILEGES, INSERT query, INSERT INTO, USE query, USE, SET ROLE or SET DEFAULT ROLE query, SET ROLE DEFAULT, SET ROLE, SET DEFAULT ROLE, SET query, SET, SYSTEM query, SYSTEM, CREATE USER or ALTER USER query, ALTER USER, CREATE USER, CREATE ROLE or ALTER ROLE query, ALTER ROLE, CREATE ROLE, CREATE QUOTA or ALTER QUOTA query, ALTER QUOTA, CREATE QUOTA, CREATE ROW POLICY or ALTER ROW POLICY query, CREATE SETTINGS PROFILE or ALTER SETTINGS PROFILE query, CREATE FUNCTION query, CREATE FORMAT SCHEMA query, DROP FORMAT SCHEMA query, DROP FUNCTION query, DROP access entity query, GRANT or REVOKE query, REVOKE, GRANT, EXTERNAL DDL query, EXTERNAL DDL FROM, TCL query, BEGIN TRANSACTION, COMMIT, ROLLBACK, SET TRANSACTION SNAPSHOT, BACKUP or RESTORE query, BACKUP, RESTORE. (SYNTAX_ERROR) (version 1.3.31) (from 10.1.13.153:42820) (in query: {"columns":[{"name":"raw","type":"string"}],"name":"data_from_kafka"})
2024.01.13 04:19:33.355240 [ 34 ] {95168f0d-aa46-439f-844c-b1e0fe0fcd4e} <Error> DynamicQueryHandler: Code: 62. DB::Exception: Syntax error: failed at position 1 ('{'): {"columns":[{"name":"raw","type":"string"}],"name":"data_from_kafka"}. Expected one of: Query, Query with output, EXPLAIN, SELECT query, possibly with UNION, list of union elements, SELECT query, subquery, possibly with UNION, SELECT subquery, SELECT query, WITH, SELECT, SUBSCRIBE TO SELECT query, possibly with UNION, SUBSCRIBE, UNSUBSCRIBE FROM SELECT query, possibly with UNION SETTINGS query_id=uuid, UNSUBSCRIBE, RECOVER FROM SELECT query, possibly with UNION SETTINGS query_id=uuid, RECOVER, SHOW CREATE QUOTA query, SHOW CREATE, SHOW CREATE FORMAT SCHEMA query, SHOW, SHOW [TEMPORARY] TABLES|DATABASES|CLUSTERS|CLUSTER 'name' [[NOT] [I]LIKE 'str'] [LIMIT expr], EXISTS or SHOW CREATE query, EXISTS, DESCRIBE FILESYSTEM CACHE query, DESCRIBE, DESC, DESCRIBE query, SHOW PROCESSLIST query, SHOW PROCESSLIST, CREATE STREAM or ATTACH STREAM query, CREATE, ATTACH, CREATE DATABASE query, CREATE VIEW query, CREATE DICTIONARY, CREATE MATERIALIZED VIEW query, ALTER query, ALTER STREAM, ALTER DATABASE, RENAME query, RENAME STREAM, DROP query, DROP, DETACH, TRUNCATE, CHECK TABLE, KILL QUERY query, KILL, OPTIMIZE query, OPTIMIZE TABLE, WATCH query, WATCH, SHOW FORMAT SCHEMAS query, SHOW ACCESS query, SHOW ACCESS, ShowAccessEntitiesQuery, SHOW GRANTS query, SHOW GRANTS, SHOW PRIVILEGES query, SHOW PRIVILEGES, INSERT query, INSERT INTO, USE query, USE, SET ROLE or SET DEFAULT ROLE query, SET ROLE DEFAULT, SET ROLE, SET DEFAULT ROLE, SET query, SET, SYSTEM query, SYSTEM, CREATE USER or ALTER USER query, ALTER USER, CREATE USER, CREATE ROLE or ALTER ROLE query, ALTER ROLE, CREATE ROLE, CREATE QUOTA or ALTER QUOTA query, ALTER QUOTA, CREATE QUOTA, CREATE ROW POLICY or ALTER ROW POLICY query, CREATE SETTINGS PROFILE or ALTER SETTINGS PROFILE query, CREATE FUNCTION query, CREATE FORMAT SCHEMA query, DROP FORMAT SCHEMA query, DROP FUNCTION query, DROP access entity query, GRANT or REVOKE query, REVOKE, GRANT, EXTERNAL DDL query, EXTERNAL DDL FROM, TCL query, BEGIN TRANSACTION, COMMIT, ROLLBACK, SET TRANSACTION SNAPSHOT, BACKUP or RESTORE query, BACKUP, RESTORE. (SYNTAX_ERROR), Stack trace (when copying this message, always include the lines below):

0. Poco::Exception::Exception(std::__1::basic_string<char, std::__1::char_traits<char>, std::__1::allocator<char>> const&, int) @ 0x1ac01c99 in /usr/bin/proton
1. DB::Exception::Exception(std::__1::basic_string<char, std::__1::char_traits<char>, std::__1::allocator<char>> const&, int, bool) @ 0x1004509a in /usr/bin/proton
2. DB::parseQueryAndMovePosition(DB::IParser&, char const*&, char const*, std::__1::basic_string<char, std::__1::char_traits<char>, std::__1::allocator<char>> const&, bool, unsigned long, unsigned long) @ 0x18c33324 in /usr/bin/proton
3. DB::parseQuery(DB::IParser&, char const*, char const*, std::__1::basic_string<char, std::__1::char_traits<char>, std::__1::allocator<char>> const&, unsigned long, unsigned long) @ 0x18c333c0 in /usr/bin/proton
4. DB::executeQueryImpl(char const*, char const*, std::__1::shared_ptr<DB::Context>, bool, DB::QueryProcessingStage::Enum, DB::ReadBuffer*) @ 0x1612d25b in /usr/bin/proton
5. DB::executeQuery(DB::ReadBuffer&, DB::WriteBuffer&, bool, std::__1::shared_ptr<DB::Context>, std::__1::function<void (std::__1::basic_string<char, std::__1::char_traits<char>, std::__1::allocator<char>> const&, std::__1::basic_string<char, std::__1::char_traits<char>, std::__1::allocator<char>> const&, std::__1::basic_string<char, std::__1::char_traits<char>, std::__1::allocator<char>> const&, std::__1::basic_string<char, std::__1::char_traits<char>, std::__1::allocator<char>> const&)>, std::__1::optional<DB::FormatSettings> const&) @ 0x16132950 in /usr/bin/proton
6. DB::HTTPHandler::processQuery(DB::HTTPServerRequest&, DB::HTMLForm&, DB::HTTPServerResponse&, DB::HTTPHandler::Output&, std::__1::optional<DB::CurrentThread::QueryScope>&) @ 0x168fe072 in /usr/bin/proton
7. DB::HTTPHandler::handleRequest(DB::HTTPServerRequest&, DB::HTTPServerResponse&) @ 0x16901f76 in /usr/bin/proton
8. DB::HTTPServerConnection::run() @ 0x1695b5f2 in /usr/bin/proton
9. Poco::Net::TCPServerConnection::start() @ 0x1aaf1327 in /usr/bin/proton
10. Poco::Net::TCPServerDispatcher::run() @ 0x1aaf1805 in /usr/bin/proton
11. Poco::PooledThread::run() @ 0x1ac617e7 in /usr/bin/proton
12. Poco::ThreadImpl::runnableEntry(void*) @ 0x1ac5f382 in /usr/bin/proton
13. ? @ 0x7f57f1797609 in ?
14. __clone @ 0x7f57f16ac353 in ?
 (version 1.3.31)
2024.01.13 04:19:33.389311 [ 34 ] {025d1a64-dff7-4475-a7dd-0db1ee9752be} <Error> executeQuery: Code: 62. DB::Exception: Syntax error: failed at position 1 ('{'): {"data":[["{\"server_id\":\"q22\",\"conidEx\":\"14016011\",\"conid\":14016011,\"_updated\":1704488599988,\"6119\":\"q22\",\"85\":\"300\",\"87\":\"254K\",\"87_ra. Expected one of: Query, Query with output, EXPLAIN, SELECT query, possibly with UNION, list of union elements, SELECT query, subquery, possibly with UNION, SELECT subquery, SELECT query, WITH, SELECT, SUBSCRIBE TO SELECT query, possibly with UNION, SUBSCRIBE, UNSUBSCRIBE FROM SELECT query, possibly with UNION SETTINGS query_id=uuid, UNSUBSCRIBE, RECOVER FROM SELECT query, possibly with UNION SETTINGS query_id=uuid, RECOVER, SHOW CREATE QUOTA query, SHOW CREATE, SHOW CREATE FORMAT SCHEMA query, SHOW, SHOW [TEMPORARY] TABLES|DATABASES|CLUSTERS|CLUSTER 'name' [[NOT] [I]LIKE 'str'] [LIMIT expr], EXISTS or SHOW CREATE query, EXISTS, DESCRIBE FILESYSTEM CACHE query, DESCRIBE, DESC, DESCRIBE query, SHOW PROCESSLIST query, SHOW PROCESSLIST, CREATE STREAM or ATTACH STREAM query, CREATE, ATTACH, CREATE DATABASE query, CREATE VIEW query, CREATE DICTIONARY, CREATE MATERIALIZED VIEW query, ALTER query, ALTER STREAM, ALTER DATABASE, RENAME query, RENAME STREAM, DROP query, DROP, DETACH, TRUNCATE, CHECK TABLE, KILL QUERY query, KILL, OPTIMIZE query, OPTIMIZE TABLE, WATCH query, WATCH, SHOW FORMAT SCHEMAS query, SHOW ACCESS query, SHOW ACCESS, ShowAccessEntitiesQuery, SHOW GRANTS query, SHOW GRANTS, SHOW PRIVILEGES query, SHOW PRIVILEGES, INSERT query, INSERT INTO, USE query, USE, SET ROLE or SET DEFAULT ROLE query, SET ROLE DEFAULT, SET ROLE, SET DEFAULT ROLE, SET query, SET, SYSTEM query, SYSTEM, CREATE USER or ALTER USER query, ALTER USER, CREATE USER, CREATE ROLE or ALTER ROLE query, ALTER ROLE, CREATE ROLE, CREATE QUOTA or ALTER QUOTA query, ALTER QUOTA, CREATE QUOTA, CREATE ROW POLICY or ALTER ROW POLICY query, CREATE SETTINGS PROFILE or ALTER SETTINGS PROFILE query, CREATE FUNCTION query, CREATE FORMAT SCHEMA query, DROP FORMAT SCHEMA query, DROP FUNCTION query, DROP access entity query, GRANT or REVOKE query, REVOKE, GRANT, EXTERNAL DDL query, EXTERNAL DDL FROM, TCL query, BEGIN TRANSACTION, COMMIT, ROLLBACK, SET TRANSACTION SNAPSHOT, BACKUP or RESTORE query, BACKUP, RESTORE. (SYNTAX_ERROR) (version 1.3.31) (from 10.1.13.153:42820) (in query: {"data":[["{\"server_id\":\"q22\",\"conidEx\":\"14016011\",\"conid\":14016011,\"_updated\":1704488599988,\"6119\":\"q22\",\"85\":\"300\",\"87\":\"254K\",\"87_raw\":254000.0,\"86\":\"1863.0\",\"88\":\"100\",\"7295\":\"1825.0\",\"83\":0.0,\"31\":\"1854.0\",\"84\":\"1846.0\",\"7289\":\"85.477B\",\"7762\":\"253700\",\"7741\":\"1854.0\",\"6509\":\"ZB\",\"topic\":\"smd+14016011\"}"],["{\"server_id\":\"q36\",\"conidEx\":\"14016011\",\"conid\":14016011,\"_updated\":1704488939015,\"6119\":\"q36\",\"85\":\"300\",\"87\":\"254K\",\"87_raw\":254000.0,\"86\":\"1863.0\",\"88\":\"100\",\"7295\":\"1825.0\",\"83\":0.0,\"31\":\"1854.0\",\"84\":\"1846.0\",\"7762\":\"253700\",\"7741\":\"1854.0\",\"6509\":\"ZB\",\"topic\":\"smd+14016011\"}"],["{\"server_id\":\"q50\",\"conidEx\":\"14016011\",\"conid\":14016011,\"_updated\":1704492580220,\"6119\":\"q50\",\"7087\":\"28.111%\",\"85\":\"300\",\"87\":\"254K\",\"87_raw\":254000.0,\"86\":\"1863.0\",\"88\":\"100\",\"7295\":\"1825.0\",\"83\":0.0,\"31\":\"1854.0\",\"84\":\"1846.0\",\"7762\":\"253700\",\"7741\":\"1854.0\",\"6509\":\"ZB\",\"topic\":\"smd+14016011\"}"],["{\"server_id\":\"q64\",\"conidEx\":\"14016011\",\"conid\":14016011,\"_updated\":1704492803542,\"6119\":\"q64\",\"85\":\"300\",\"87\":\"254K\",\"87_raw\":254000.0,\"86\":\"1863.0\",\"88\":\"100\",\"7295\":\"1825.0\",\"83\":0.0,\"31\":\"1854.0\",\"84\":\"1846.0\",\"7762\":\"253700\",\"7741\":\"1854.0\",\"6509\":\"ZB\",\"topic\":\"smd+14016011\"}"],["{\"server_id\":\"q80\",\"conidEx\":\"14016916\",\"conid\":14016916,\"_updated\":1704492817880,\"6119\":\"q80\",\"7674\":\"1279.47\",\"7676\":\"1207.29\",\"7675\":\"1244.66\",\"85\":\"300\",\"87\":\"148K\",\"87_raw\":148000.0,\"86\":\"1231.0\",\"88\":\"300\",\"7677\":\"1186.86\",\"7295\":\"1246.0\",\"83\":0.0,\"31\":\"1225.0\",\"84\":\"1219.0\",\"7762\":\"148000\",\"7741\":\"1225.0\",\"6509\":\"ZB\",\"topic\":\"smd+14016916\"}"],["{\"server_id\":\"q119\",\"conidEx\":\"56984519\",\"conid\":56984519,\"_updated\":1704492817880,\"6119\":\"q119\",\"7674\":\"2544.13\",\"7676\":\"2730.48\",\"7675\":\"2681.34\",\"85\":\"100\",\"87\":\"238K\",\"87_raw\":238000.0,\"86\":\"2987.0\",\"88\":\"100\",\"7677\":\"2764.92\",\"7295\":\"2899.0\",\"83\":1.34,\"31\":\"2951.0\",\"84\":\"2984.0\",\"7762\":\"237900\",\"7741\":\"2912.0\",\"6509\":\"ZB\",\"topic\":\"smd+56984519\"}"],["{\"server_id\":\"q110\",\"conidEx\":\"316282030\",\"conid\":316282030,\"_updated\":1704492817880,\"6119\":\"q110\",\"7674\":\"1354.79\",\"7676\":\"1292.74\",\"7675\":\"1318.18\",\"85\":\"100\",\"87\":\"1.06M\",\"87_raw\":1060000.0,\"86\":\"1185.0\",\"88\":\"100\",\"7677\":\"1255.21\",\"7295\":\"1185.0\",\"83\":0.0,\"31\":\"1171.0\",\"84\":\"1171.0\",\"7762\":\"1063200\",\"7741\":\"1171.0\",\"6509\":\"ZB\",\"topic\":\"smd+316282030\"}"],["{\"server_id\":\"q75\",\"conidEx\":\"14015316\",\"conid\":14015316,\"_updated\":1704492818885,\"6119\":\"q75\",\"7674\":\"1356.86\",\"7676\":\"1628.54\",\"7675\":\"1505.98\",\"87\":\"57.2K\",\"87_raw\":57200.0,\"7677\":\"1750.50\",\"7295\":\"1898.0\",\"83\":0.0,\"31\":\"1909.0\",\"7762\":\"57200\",\"7741\":\"1909.0\",\"topic\":\"smd+14015316\"}"],["{\"server_id\":\"q114\",\"conidEx\":\"113787206\",\"conid\":113787206,\"_updated\":1704492818885,\"6119\":\"q114\",\"7674\":\"2791.00\",\"7676\":\"2810.44\",\"7675\":\"2826.59\",\"87\":\"4.20M\",\"87_raw\":4200000.0,\"7677\":\"2790.62\",\"7295\":\"2790.0\",\"83\":0.09,\"31\":\"2789.0\",\"7762\":\"4204200\",\"7741\":\"2786.5\",\"topic\":\"smd+113787206\"}"],["{\"server_id\":\"q98\",\"conidEx\":\"128713428\",\"conid\":128713428,\"_updated\":1704492818886,\"6119\":\"q98\",\"7674\":\"2394.48\",\"7676\":\"2298.96\",\"7675\":\"2347.04\",\"87\":\"271K\",\"87_raw\":271000.0,\"7677\":\"2302.42\",\"7295\":\"2364.5\",\"83\":0.0,\"31\":\"2328.5\",\"7762\":\"270600\",\"7741\":\"2328.5\",\"topic\":\"smd+128713428\"}"],["{\"server_id\":\"q135\",\"conidEx\":\"49939805\",\"conid\":49939805,\"_updated\":1704492818886,\"6119\":\"q135\",\"7674\":\"1582.26\",\"7676\":\"1634.39\",\"7675\":\"1593.59\",\"85\":\"100\",\"87\":\"138K\",\"87_raw\":138000.0,\"86\":\"1843.0\",\"88\":\"100\",\"7677\":\"1713.35\",\"7295\":\"1775.0\",\"83\":0.4,\"31\":\"1750.0\",\"84\":\"1721.0\",\"7762\":\"137800\",\"7741\":\"1743.0\",\"6509\":\"ZB\",\"topic\":\"smd+49939805\"}"],["{\"server_id\":\"q136\",\"conidEx\":\"14014836\",\"conid\":14014836,\"_updated\":1704492818886,\"6119\":\"q136\",\"7674\":\"2206.98\",\"7676\":\"2279.46\",\"7675\":\"2275.70\",\"87\":\"30.0K\",\"87_raw\":30000.0,\"7677\":\"2289.39\",\"7295\":\"2397.0\",\"83\":0.0,\"31\":\"2387.0\",\"7762\":\"30000\",\"7741\":\"2387.0\",\"6509\":\"ZB\",\"topic\":\"smd+14014836\"}"],["{\"server_id\":\"q155\",\"conidEx\":\"295291791\",\"conid\":295291791,\"_updated\":1704492818886,\"6119\":\"q155\",\"7674\":\"2041.69\",\"7676\":\"2057.60\",\"7675\":\"2048.22\",\"85\":\"100\",\"87\":\"1.01M\",\"87_raw\":1010000.0,\"86\":\"2070.0\",\"88\":\"300\",\"7677\":\"2055.09\",\"7295\":\"2096.0\",\"83\":0.15,\"31\":\"2070.0\",\"84\":\"2057.4\",\"7762\":\"1005500\",\"7741\":\"2067.0\",\"6509\":\"ZB\",\"topic\":\"smd+295291791\"}"],["{\"88\":\"100\",\"7087\":\"28.111%\",\"conidEx\":\"14016011\",\"7741\":\"1854.0\",\"7762\":\"253700\",\"7289\":\"85.477B\",\"7284\":\"28.111%\",\"6509\":\"ZB\",\"7636\":\"102,732\",\"31\":\"1854.0\",\"55\":\"5351\",\"7675\":\"1508.58\",\"7674\":\"1304.08\",\"7677\":\"1708.20\",\"7676\":\"1635.83\",\"_updated\":1704492817880,\"87_raw\":254000.0,\"server_id\":\"q64\",\"7295\":\"1825.0\",\"topic\":\"smd+14016011\",\"conid\":14016011,\"6119\":\"q64\",\"83\":0.0,\"84\":\"1846.0\",\"85\":\"300\",\"86\":\"1863.0\",\"87\":\"254K\"}"],["{\"88\":\"100\",\"7087\":\"31.319%\",\"conidEx\":\"14015316\",\"7741\":\"1909.0\",\"7289\":\"24.72B\",\"7762\":\"57200\",\"7284\":\"31.319%\",\"6509\":\"ZB\",\"7636\":\"19,833\",\"31\":\"1909.0\",\"55\":\"3877\",\"7675\":\"1505.98\",\"7674\":\"1356.86\",\"7677\":\"1750.50\",\"7676\":\"1628.54\",\"_updated\":1704492818885,\"87_raw\":57200.0,\"server_id\":\"q75\",\"7295\":\"1898.0\",\"topic\":\"smd+14015316\",\"conid\":14015316,\"6119\":\"q75\",\"83\":0.0,\"84\":\"1860.0\",\"85\":\"100\",\"86\":\"2100.0\",\"87\":\"57.2K\"}"],["{\"88\":\"300\",\"7087\":\"38.051%\",\"conidEx\":\"14016916\",\"7741\":\"1225.0\",\"7289\":\"29.026B\",\"7762\":\"148000\",\"7284\":\"38.051%\",\"6509\":\"ZB\",\"7636\":\"29,201\",\"31\":\"1225.0\",\"55\":\"6779\",\"7675\":\"1244.66\",\"7674\":\"1279.47\",\"7677\":\"1186.86\",\"7676\":\"1207.29\",\"_updated\":1704492817880,\"87_raw\":148000.0,\"server_id\":\"q80\",\"7295\":\"1246.0\",\"topic\":\"smd+14016916\",\"conid\":14016916,\"6119\":\"q80\",\"83\":0.0,\"84\":\"1219.0\",\"85\":\"300\",\"86\":\"1231.0\",\"87\":\"148K\"}"],["{\"88\":\"300\",\"7087\":\"21.973%\",\"conidEx\":\"128713428\",\"7741\":\"2328.5\",\"7289\":\"207.669B\",\"7762\":\"270600\",\"7284\":\"21.973%\",\"6509\":\"ZB\",\"7636\":\"480,156\",\"31\":\"2328.5\",\"55\":\"3765\",\"7675\":\"2347.04\",\"7674\":\"2394.48\",\"7677\":\"2302.42\",\"7676\":\"2298.96\",\"_updated\":1704492818886,\"87_raw\":271000.0,\"server_id\":\"q98\",\"7295\":\"2364.5\",\"topic\":\"smd+128713428\",\"conid\":128713428,\"6119\":\"q98\",\"83\":0.0,\"84\":\"2317.5\",\"85\":\"300\",\"86\":\"2339.5\",\"87\":\"271K\"}"],["{\"88\":\"100\",\"7087\":\"49.208%\",\"conidEx\":\"316282030\",\"7741\":\"1171.0\",\"7289\":\"72.38B\",\"7762\":\"1063200\",\"7284\":\"49.208%\",\"6509\":\"ZB\",\"31\":\"1171.0\",\"55\":\"4384\",\"7675\":\"1318.18\",\"7674\":\"1354.79\",\"7677\":\"1255.21\",\"7676\":\"1292.74\",\"_updated\":1704492817880,\"87_raw\":1060000.0,\"server_id\":\"q110\",\"7295\":\"1185.0\",\"topic\":\"smd+316282030\",\"conid\":316282030,\"6119\":\"q110\",\"83\":0.0,\"84\":\"1171.0\",\"85\":\"100\",\"86\":\"1185.0\",\"87\":\"1.06M\"}"],["{\"88\":\"100\",\"7087\":\"17.967%\",\"conidEx\":\"113787206\",\"7741\":\"2786.5\",\"7289\":\"1,222.472B\",\"7762\":\"4204200\",\"7284\":\"17.967%\",\"6509\":\"ZB\",\"7636\":\"926,110\",\"31\":\"2789.0\",\"55\":\"9201\",\"7675\":\"2826.59\",\"7674\":\"2791.00\",\"7677\":\"2790.62\",\"7676\":\"2810.44\",\"_updated\":1704492818885,\"87_raw\":4200000.0,\"server_id\":\"q114\",\"7295\":\"2790.0\",\"topic\":\"smd+113787206\",\"conid\":113787206,\"6119\":\"q114\",\"83\":0.09,\"84\":\"2786.1\",\"85\":\"400\",\"86\":\"2787.5\",\"87\":\"4.20M\"}"],["{\"88\":\"100\",\"7087\":\"25.560%\",\"conidEx\":\"56984519\",\"7741\":\"2912.0\",\"7289\":\"109.94B\",\"7762\":\"237900\",\"7284\":\"25.560%\",\"6509\":\"ZB\",\"31\":\"2951.0\",\"55\":\"7611\",\"7675\":\"2681.34\",\"7674\":\"2544.13\",\"7677\":\"2764.92\",\"7676\":\"2730.48\",\"_updated\":1704492817880,\"87_raw\":238000.0,\"server_id\":\"q119\",\"7295\":\"2899.0\",\"topic\":\"smd+56984519\",\"conid\":56984519,\"6119\":\"q119\",\"83\":1.34,\"84\":\"2984.0\",\"85\":\"100\",\"86\":\"2987.0\",\"87\":\"238K\"}"],["{\"88\":\"100\",\"7087\":\"53.588%\",\"conidEx\":\"49939805\",\"7741\":\"1743.0\",\"7289\":\"15.833B\",\"7762\":\"137800\",\"7284\":\"53.588%\",\"6509\":\"ZB\",\"31\":\"1750.0\",\"55\":\"6668\",\"7675\":\"1593.59\",\"7674\":\"1582.26\",\"7677\":\"1713.35\",\"7676\":\"1634.39\",\"_updated\":1704492818886,\"87_raw\":138000.0,\"server_id\":\"q135\",\"7295\":\"1775.0\",\"topic\":\"smd+49939805\",\"conid\":49939805,\"6119\":\"q135\",\"83\":0.4,\"84\":\"1721.0\",\"85\":\"100\",\"86\":\"1843.0\",\"87\":\"138K\"}"],["{\"55\":\"1952\",\"7087\":\"16.768%\",\"conidEx\":\"14014836\",\"7675\":\"2275.70\",\"7741\":\"2387.0\",\"7289\":\"58.496B\",\"7674\":\"2206.98\",\"7762\":\"30000\",\"7677\":\"2289.39\",\"7676\":\"2279.46\",\"_updated\":1704492818886,\"87_raw\":30000.0,\"server_id\":\"q136\",\"7284\":\"16.768%\",\"7295\":\"2397.0\",\"6509\":\"ZB\",\"topic\":\"smd+14014836\",\"conid\":14014836,\"6119\":\"q136\",\"7636\":\"23,855\",\"83\":0.0,\"31\":\"2387.0\",\"87\":\"30.0K\"}"],["{\"88\":\"300\",\"7087\":\"22.257%\",\"conidEx\":\"295291791\",\"7741\":\"2067.0\",\"7289\":\"1,348.35B\",\"7762\":\"1005500\",\"7284\":\"22.257%\",\"6509\":\"ZB\",\"7636\":\"1,951,823\",\"31\":\"2070.0\",\"55\":\"9143\",\"7675\":\"2048.22\",\"7674\":\"2041.69\",\"7677\":\"2055.09\",\"7676\":\"2057.60\",\"_updated\":1704492818886,\"87_raw\":1010000.0,\"server_id\":\"q155\",\"7295\":\"2096.0\",\"topic\":\"smd+295291791\",\"conid\":295291791,\"6119\":\"q155\",\"83\":0.15,\"84\":\"2057.4\",\"85\":\"100\",\"86\":\"2070.0\",\"87\":\"1.01M\"}"],["{\"server_id\":\"q199\",\"conidEx\":\"128713428\",\"conid\":128713428,\"_updated\":1704493885442,\"6119\":\"q199\",\"7636\":\"480,156\",\"7674\":\"2394.48\",\"7087\":\"21.973%\",\"7676\":\"2298.96\",\"7675\":\"2347.04\",\"85\":\"300\",\"7284\":\"21.973%\",\"87\":\"271K\",\"87_raw\":271000.0,\"86\":\"2339.5\",\"88\":\"300\",\"7677\":\"2302.42\",\"7295\":\"2364.5\",\"83\":0.0,\"31\":\"2328.5\",\"84\":\"2317.5\",\"7762\":\"270600\",\"7741\":\"2328.5\",\"6509\":\"ZB\",\"topic\":\"smd+128713428\"}"],["{\"server_id\":\"q176\",\"conidEx\":\"14015316\",\"conid\":14015316,\"_updated\":1704493885443,\"6119\":\"q176\",\"7636\":\"19,833\",\"7674\":\"1356.86\",\"7087\":\"31.319%\",\"7676\":\"1628.54\",\"7675\":\"1505.98\",\"85\":\"100\",\"7284\":\"31.319%\",\"87\":\"57.2K\",\"87_raw\":57200.0,\"86\":\"2100.0\",\"88\":\"100\",\"7677\":\"1750.50\",\"7295\":\"1898.0\",\"83\":0.0,\"31\":\"1909.0\",\"84\":\"1860.0\",\"7762\":\"57200\",\"7741\":\"1909.0\",\"6509\":\"ZB\",\"topic\":\"smd+14015316\"}"],["{\"server_id\":\"q165\",\"conidEx\":\"14016011\",\"conid\":14016011,\"_updated\":1704493885443,\"6119\":\"q165\",\"7636\":\"102,732\",\"7674\":\"1304.08\",\"7087\":\"28.111%\",\"7676\":\"1635.83\",\"7675\":\"1508.58\",\"85\":\"300\",\"7284\":\"28.111%\",\"87\":\"254K\",\"87_raw\":254000.0,\"86\":\"1863.0\",\"88\":\"100\",\"7677\":\"1708.20\",\"7295\":\"1825.0\",\"83\":0.0,\"31\":\"1854.0\",\"84\":\"1846.0\",\"7762\":\"253700\",\"7741\":\"1854.0\",\"6509\":\"ZB\",\"topic\":\"smd+14016011\"}"],["{\"server_id\":\
2024.01.13 04:19:33.391664 [ 34 ] {025d1a64-dff7-4475-a7dd-0db1ee9752be} <Error> DynamicQueryHandler: Code: 62. DB::Exception: Syntax error: failed at position 1 ('{'): {"data":[["{\"server_id\":\"q22\",\"conidEx\":\"14016011\",\"conid\":14016011,\"_updated\":1704488599988,\"6119\":\"q22\",\"85\":\"300\",\"87\":\"254K\",\"87_ra. Expected one of: Query, Query with output, EXPLAIN, SELECT query, possibly with UNION, list of union elements, SELECT query, subquery, possibly with UNION, SELECT subquery, SELECT query, WITH, SELECT, SUBSCRIBE TO SELECT query, possibly with UNION, SUBSCRIBE, UNSUBSCRIBE FROM SELECT query, possibly with UNION SETTINGS query_id=uuid, UNSUBSCRIBE, RECOVER FROM SELECT query, possibly with UNION SETTINGS query_id=uuid, RECOVER, SHOW CREATE QUOTA query, SHOW CREATE, SHOW CREATE FORMAT SCHEMA query, SHOW, SHOW [TEMPORARY] TABLES|DATABASES|CLUSTERS|CLUSTER 'name' [[NOT] [I]LIKE 'str'] [LIMIT expr], EXISTS or SHOW CREATE query, EXISTS, DESCRIBE FILESYSTEM CACHE query, DESCRIBE, DESC, DESCRIBE query, SHOW PROCESSLIST query, SHOW PROCESSLIST, CREATE STREAM or ATTACH STREAM query, CREATE, ATTACH, CREATE DATABASE query, CREATE VIEW query, CREATE DICTIONARY, CREATE MATERIALIZED VIEW query, ALTER query, ALTER STREAM, ALTER DATABASE, RENAME query, RENAME STREAM, DROP query, DROP, DETACH, TRUNCATE, CHECK TABLE, KILL QUERY query, KILL, OPTIMIZE query, OPTIMIZE TABLE, WATCH query, WATCH, SHOW FORMAT SCHEMAS query, SHOW ACCESS query, SHOW ACCESS, ShowAccessEntitiesQuery, SHOW GRANTS query, SHOW GRANTS, SHOW PRIVILEGES query, SHOW PRIVILEGES, INSERT query, INSERT INTO, USE query, USE, SET ROLE or SET DEFAULT ROLE query, SET ROLE DEFAULT, SET ROLE, SET DEFAULT ROLE, SET query, SET, SYSTEM query, SYSTEM, CREATE USER or ALTER USER query, ALTER USER, CREATE USER, CREATE ROLE or ALTER ROLE query, ALTER ROLE, CREATE ROLE, CREATE QUOTA or ALTER QUOTA query, ALTER QUOTA, CREATE QUOTA, CREATE ROW POLICY or ALTER ROW POLICY query, CREATE SETTINGS PROFILE or ALTER SETTINGS PROFILE query, CREATE FUNCTION query, CREATE FORMAT SCHEMA query, DROP FORMAT SCHEMA query, DROP FUNCTION query, DROP access entity query, GRANT or REVOKE query, REVOKE, GRANT, EXTERNAL DDL query, EXTERNAL DDL FROM, TCL query, BEGIN TRANSACTION, COMMIT, ROLLBACK, SET TRANSACTION SNAPSHOT, BACKUP or RESTORE query, BACKUP, RESTORE. (SYNTAX_ERROR), Stack trace (when copying this message, always include the lines below):
9c0} <Error> executeQuery: Code: 62. DB::Exception: Syntax error: failed at position 1 ('{'): {"data":[["{\"server_id\":\"q70\",\"conidEx\":\"113787206\",\"conid\":113787206,\"_updated\":1704758790596,\"6119\":\"q70\",\"7677\":\"2793.06\",\"88\":\"1,800\. Expected one of: Query, Query with output, EXPLAIN, SELECT query, possibly with UNION, list of union elements, SELECT query, subquery, possibly with UNION, SELECT subquery, SELECT query, WITH, SELECT, SUBSCRIBE TO SELECT query, possibly with UNION, SUBSCRIBE, UNSUBSCRIBE FROM SELECT query, possibly with UNION SETTINGS query_id=uuid, UNSUBSCRIBE, RECOVER FROM SELECT query, possibly with UNION SETTINGS query_id=uuid, RECOVER, SHOW CREATE QUOTA query, SHOW CREATE, SHOW CREATE FORMAT SCHEMA query, SHOW, SHOW [TEMPORARY] TABLES|DATABASES|CLUSTERS|CLUSTER 'name' [[NOT] [I]LIKE 'str'] [LIMIT expr], EXISTS or SHOW CREATE query, EXISTS, DESCRIBE FILESYSTEM CACHE query, DESCRIBE, DESC, DESCRIBE query, SHOW PROCESSLIST query, SHOW PROCESSLIST, CREATE STREAM or ATTACH STREAM query, CREATE, ATTACH, CREATE DATABASE query, CREATE VIEW query, CREATE DICTIONARY, CREATE MATERIALIZED VIEW query, ALTER query, ALTER STREAM, ALTER DATABASE, RENAME query, RENAME STREAM, DROP query, DROP, DETACH, TRUNCATE, CHECK TABLE, KILL QUERY query, KILL, OPTIMIZE query, OPTIMIZE TABLE, WATCH query, WATCH, SHOW FORMAT SCHEMAS query, SHOW ACCESS query, SHOW ACCESS, ShowAccessEntitiesQuery, SHOW GRANTS query, SHOW GRANTS, SHOW PRIVILEGES query, SHOW PRIVILEGES, INSERT query, INSERT INTO, USE query, USE, SET ROLE or SET DEFAULT ROLE query, SET ROLE DEFAULT, SET ROLE, SET DEFAULT ROLE, SET query, SET, SYSTEM query, SYSTEM, CREATE USER or ALTER USER query, ALTER USER, CREATE USER, CREATE ROLE or ALTER ROLE query, ALTER ROLE, CREATE ROLE, CREATE QUOTA or ALTER QUOTA query, ALTER QUOTA, CREATE QUOTA, CREATE ROW POLICY or ALTER ROW POLICY query, CREATE SETTINGS PROFILE or ALTER SETTINGS PROFILE query, CREATE FUNCTION query, CREATE FORMAT SCHEMA query, DROP FORMAT SCHEMA query, DROP FUNCTION query, DROP access entity query, GRANT or REVOKE query, REVOKE, GRANT, EXTERNAL DDL query, EXTERNAL DDL FROM, TCL query, BEGIN TRANSACTION, COMMIT, ROLLBACK, SET TRANSACTION SNAPSHOT, BACKUP or RESTORE query, BACKUP, RESTORE. (SYNTAX_ERROR) (version 1.3.31) (from 10.1.13.153:42820) (in query: {"data":[["{\"server_id\":\"q70\",\"conidEx\":\"113787206\",\"conid\":113787206,\"_updated\":1704758790596,\"6119\":\"q70\",\"7677\":\"2793.06\",\"88\":\"1,800\",\"7762\":\"413200\",\"7676\":\"2810.65\",\"31\":\"2818.5\",\"7675\":\"2826.38\",\"83\":1.15,\"7674\":\"2791.22\",\"topic\":\"smd+113787206\"}"],["{\"server_id\":\"q70\",\"conidEx\":\"113787206\",\"conid\":113787206,\"_updated\":1704758791598,\"6119\":\"q70\",\"7677\":\"2793.15\",\"7762\":\"413500\",\"7676\":\"2810.69\",\"31\":\"2819.5\",\"7675\":\"2826.40\",\"83\":1.18,\"87\":\"414K\",\"87_raw\":414000.0,\"7674\":\"2791.23\",\"85\":\"1,000\",\"topic\":\"smd+113787206\"}"],["{\"server_id\":\"q31\",\"conidEx\":\"14015316\",\"conid\":14015316,\"_updated\":1704758792100,\"6119\":\"q31\",\"7677\":\"1774.17\",\"7762\":\"62500\",\"7676\":\"1643.06\",\"31\":\"1999.0\",\"7675\":\"1515.74\",\"83\":4.71,\"87\":\"62.5K\",\"87_raw\":62500.0,\"7674\":\"1363.30\",\"85\":\"400\",\"topic\":\"smd+14015316\"}"],["{\"server_id\":\"q111\",\"conidEx\":\"295291791\",\"conid\":295291791,\"_updated\":1704758792602,\"6119\":\"q111\",\"7677\":\"2057.93\",\"88\":\"100\",\"86\":\"2088.5\",\"7762\":\"48800\",\"7676\":\"2058.69\",\"31\":\"2088.0\",\"7675\":\"2048.92\",\"83\":1.02,\"84\":\"2087.0\",\"87\":\"48.8K\",\"87_raw\":48800.0,\"topic\":\"smd+295291791\"}"],["{\"server_id\":\"q75\",\"conidEx\":\"56984519\",\"conid\":56984519,\"_updated\":1704758793604,\"6119\":\"q75\",\"7677\":\"2779.57\",\"7762\":\"76800\",\"7676\":\"2737.79\",\"31\":\"2954.0\",\"7675\":\"2685.96\",\"83\":1.44,\"87\":\"76.8K\",\"87_raw\":76800.0,\"7674\":\"2547.84\",\"85\":\"400\",\"topic\":\"smd+56984519\"}"],["{\"server_id\":\"q111\",\"conidEx\":\"295291791\",\"conid\":295291791,\"_updated\":1704758793604,\"6119\":\"q111\",\"7677\":\"2058.03\",\"86\":\"2090.0\",\"7762\":\"49000\",\"7676\":\"2058.73\",\"31\":\"2089.0\",\"7675\":\"2048.94\",\"83\":1.06,\"84\":\"2088.0\",\"87\":\"49.0K\",\"87_raw\":49000.0,\"7674\":\"2042.14\",\"85\":\"200\",\"topic\":\"smd+295291791\"}"],["{\"server_id\":\"q31\",\"conidEx\":\"14015316\",\"conid\":14015316,\"_updated\":1704758794105,\"6119\":\"q31\",\"7677\":\"1774.26\",\"88\":\"100\",\"86\":\"2004.0\",\"7762\":\"62900\",\"7676\":\"1643.10\",\"31\":\"2000.0\",\"7675\":\"1515.76\",\"83\":4.77,\"84\":\"1995.0\",\"87\":\"62.9K\",\"87_raw\":62900.0,\"7674\":\"1363.31\",\"85\":\"300\",\"topic\":\"smd+14015316\"}"],["{\"server_id\":\"q70\",\"conidEx\":\"113787206\",\"conid\":113787206,\"_updated\":1704758794607,\"6119\":\"q70\",\"7677\":\"2793.06\",\"88\":\"1,200\",\"86\":\"2819.0\",\"7762\":\"415200\",\"7676\":\"2810.65\",\"31\":\"2818.5\",\"7675\":\"2826.38\",\"83\":1.15,\"84\":\"2818.0\",\"87\":\"415K\",\"87_raw\":415000.0,\"7674\":\"2791.22\",\"85\":\"100\",\"topic\":\"smd+113787206\"}"],["{\"server_id\":\"q20\",\"conidEx\":\"14016011\",\"conid\":14016011,\"_updated\":1704758795609,\"6119\":\"q20\",\"7677\":\"1725.24\",\"88\":\"300\",\"86\":\"1889.0\",\"7762\":\"29100\",\"7676\":\"1645.68\",\"31\":\"1887.0\",\"7675\":\"1516.08\",\"83\":1.78,\"84\":\"1886.0\",\"87\":\"29.1K\",\"87_raw\":29100.0,\"7674\":\"1309.88\",\"85\":\"1,000\",\"topic\":\"smd+14016011\"}"],["{\"server_id\":\"q91\",\"conidEx\":\"49939805\",\"conid\":49939805,\"_updated\":1704758796110,\"6119\":\"q91\",\"7677\":\"1723.09\",\"86\":\"1823.0\",\"7762\":\"16600\",\"7676\":\"1641.50\",\"31\":\"1822.0\",\"7675\":\"1598.01\",\"83\":4.53,\"84\":\"1816.0\",\"87\":\"16.6K\",\"87_raw\":16600.0,\"7674\":\"1584.60\",\"topic\":\"smd+49939805\"}"],["{\"server_id\":\"q66\",\"conidEx\":\"316282030\",\"conid\":316282030,\"_updated\":1704758796611,\"6119\":\"q66\",\"7677\":\"1247.37\",\"88\":\"300\",\"86\":\"1174.0\",\"7762\":\"73200\",\"7676\":\"1288.03\",\"31\":\"1173.0\",\"7675\":\"1315.28\",\"83\":0.17,\"87\":\"73.2K\",\"87_raw\":73200.0,\"7674\":\"1352.98\",\"85\":\"100\",\"topic\":\"smd+316282030\"}"],["{\"server_id\":\"q70\",\"conidEx\":\"113787206\",\"conid\":113787206,\"_updated\":1704758799118,\"6119\":\"q70\",\"7677\":\"2793.11\",\"88\":\"200\",\"86\":\"2819.5\",\"7762\":\"415300\",\"7676\":\"2810.67\",\"31\":\"2819.0\",\"7675\":\"2826.39\",\"83\":1.17,\"84\":\"2818.5\",\"7674\":\"2791.23\",\"85\":\"1,100\",\"topic\":\"smd+113787206\"}"],["{\"server_id\":\"q70\",\"conidEx\":\"113787206\",\"conid\":113787206,\"_updated\":1704758799619,\"6119\":\"q70\",\"7677\":\"2793.15\",\"88\":\"1,100\",\"7762\":\"417200\",\"7676\":\"2810.69\",\"31\":\"2819.5\",\"7675\":\"2826.40\",\"83\":1.18,\"87\":\"417K\",\"87_raw\":417000.0,\"85\":\"100\",\"topic\":\"smd+113787206\"}"],["{\"server_id\":\"q70\",\"conidEx\":\"113787206\",\"conid\":113787206,\"_updated\":1704758800120,\"6119\":\"q70\",\"7677\":\"2793.20\",\"88\":\"100\",\"86\":\"2821.0\",\"7762\":\"417300\",\"7676\":\"2810.71\",\"31\":\"2820.0\",\"7675\":\"2826.41\",\"83\":1.2,\"84\":\"2819.5\",\"7674\":\"2791.24\",\"85\":\"400\",\"topic\":\"smd+113787206\"}"],["{\"server_id\":\"q75\",\"conidEx\":\"56984519\",\"conid\":56984519,\"_updated\":1704758800120,\"6119\":\"q75\",\"7677\":\"2778.43\",\"86\":\"2950.0\",\"7762\":\"77000\",\"7676\":\"2737.31\",\"31\":\"2942.0\",\"7675\":\"2685.73\",\"83\":1.03,\"84\":\"2940.0\",\"87\":\"77.0K\",\"87_raw\":77000.0,\"7674\":\"2547.72\",\"85\":\"100\",\"topic\":\"smd+56984519\"}"],["{\"server_id\":\"q70\",\"conidEx\":\"113787206\",\"conid\":113787206,\"_updated\":1704758801123,\"6119\":\"q70\",\"7677\":\"2793.25\",\"88\":\"600\",\"7762\":\"449600\",\"7676\":\"2810.73\",\"31\":\"2820.5\",\"7675\":\"2826.42\",\"83\":1.22,\"87\":\"450K\",\"87_raw\":450000.0,\"85\":\"100\",\"topic\":\"smd+113787206\"}"],["{\"server_id\":\"q111\",\"conidEx\":\"295291791\",\"conid\":295291791,\"_updated\":1704758801123,\"6119\":\"q111\",\"7677\":\"2058.08\",\"88\":\"300\",\"86\":\"2090.5\",\"7762\":\"49100\",\"7676\":\"2058.75\",\"31\":\"2089.5\",\"7675\":\"2048.95\",\"83\":1.09,\"84\":\"2088.5\",\"87\":\"49.1K\",\"87_raw\":49100.0,\"7674\":\"2042.15\",\"topic\":\"smd+295291791\"}"],["{\"server_id\":\"q70\",\"conidEx\":\"113787206\",\"conid\":113787206,\"_updated\":1704758802125,\"6119\":\"q70\",\"7677\":\"2793.39\",\"86\":\"2822.0\",\"7762\":\"451500\",\"7676\":\"2810.79\",\"31\":\"2822.0\",\"7675\":\"2826.45\",\"83\":1.27,\"84\":\"2821.0\",\"87\":\"452K\",\"87_raw\":452000.0,\"7674\":\"2791.26\",\"85\":\"6,400\",\"topic\":\"smd+113787206\"}"],["{\"server_id\":\"q70\",\"conidEx\":\"113787206\",\"conid\":113787206,\"_updated\":1704758802628,\"6119\":\"q70\",\"7677\":\"2793.30\",\"7762\":\"451600\",\"7676\":\"2810.75\",\"31\":\"2821.0\",\"7675\":\"2826.43\",\"83\":1.24,\"7674\":\"2791.25\",\"7284\":\"18.256%\",\"7087\":\"18.256%\",\"topic\":\"smd+113787206\"}"],["{\"server_id\":\"q70\",\"conidEx\":\"113787206\",\"conid\":113787206,\"_updated\":1704758803630,\"6119\":\"q70\",\"7677\":\"2793.49\",\"88\":\"4,800\",\"86\":\"2823.0\",\"7762\":\"459300\",\"7676\":\"2810.83\",\"31\":\"2823.0\",\"7675\":\"2826.47\",\"83\":1.31,\"84\":\"2822.0\",\"87\":\"459K\",\"87_raw\":459000.0,\"7674\":\"2791.27\",\"85\":\"100\",\"topic\":\"smd+113787206\"}"],["{\"server_id\":\"q75\",\"conidEx\":\"56984519\",\"conid\":56984519,\"_updated\":1704758803630,\"6119\":\"q75\",\"7677\":\"2778.52\",\"86\":\"2946.0\",\"7762\":\"77500\",\"7676\":\"2737.35\",\"31\":\"2943.0\",\"7675\":\"2685.75\",\"83\":1.06

My connector config is:

apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaConnector
metadata:
  name: proton-timeplus-sink
  labels:
    strimzi.io/cluster: {{ .Release.Name }}
spec:
  class: com.timeplus.kafkaconnect.TimeplusSinkConnector
  tasksMax: 1
  config:
    tasksMax: 1
    topics: ticks-japan-l1
    timeplus.sink.address: http://stage-data-analytics-proton:3218
    timeplus.sink.workspace: <leave empty>
    timeplus.sink.apikey: <leave empty>
    timeplus.sink.stream: data_from_kafka
    timeplus.sink.createStream: true
    timeplus.sink.dataFormat: raw
    key.converter: org.apache.kafka.connect.storage.StringConverter
    value.converter: org.apache.kafka.connect.storage.StringConverter

My Kafka Connect cluster error message is:

01-13 04:19:33,155 INFO [proton-timeplus-sink|task-0] [Consumer clientId=connector-consumer-proton-timeplus-sink-0, groupId=connect-proton-timeplus-sink] Resetting offset for partition ticks-japan-l1-2 to position FetchPosition{offset=864, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[stage-message-bus-redpanda-0.stage-message-bus-redpanda.stage.svc.cluster.local.:9093 (id: 0 rack: null)], epoch=absent}}. (org.apache.kafka.clients.consumer.internals.SubscriptionState) [task-thread-proton-timeplus-sink-0]
2024-01-13 04:19:33,339 INFO 192.168.1.82 - - [13/Jan/2024:04:19:33 +0000] "GET / HTTP/1.1" 200 114 "-" "kube-probe/1.28" 1 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp1882485538-278]
2024-01-13 04:19:33,340 INFO 192.168.1.82 - - [13/Jan/2024:04:19:33 +0000] "GET / HTTP/1.1" 200 114 "-" "kube-probe/1.28" 3 (org.apache.kafka.connect.runtime.rest.RestServer) [qtp1882485538-281]
Jan 13, 2024 4:19:33 AM com.timeplus.kafkaconnect.TimeplusSinkTask createStream
INFO: create stream failed Code: 62. DB::Exception: Syntax error: failed at position 1 ('{'): {"columns":[{"name":"raw","type":"string"}],"name":"data_from_kafka"}. Expected one of: Query, Query with output, EXPLAIN, SELECT query, possibly with UNION, list of union elements, SELECT query, subquery, possibly with UNION, SELECT subquery, SELECT query, WITH, SELECT, SUBSCRIBE TO SELECT query, possibly with UNION, SUBSCRIBE, UNSUBSCRIBE FROM SELECT query, possibly with UNION SETTINGS query_id=uuid, UNSUBSCRIBE, RECOVER FROM SELECT query, possibly with UNION SETTINGS query_id=uuid, RECOVER, SHOW CREATE QUOTA query, SHOW CREATE, SHOW CREATE FORMAT SCHEMA query, SHOW, SHOW [TEMPORARY] TABLES|DATABASES|CLUSTERS|CLUSTER 'name' [[NOT] [I]LIKE 'str'] [LIMIT expr], EXISTS or SHOW CREATE query, EXISTS, DESCRIBE FILESYSTEM CACHE query, DESCRIBE, DESC, DESCRIBE query, SHOW PROCESSLIST query, SHOW PROCESSLIST, CREATE STREAM or ATTACH STREAM query, CREATE, ATTACH, CREATE DATABASE query, CREATE VIEW query, CREATE DICTIONARY, CREATE MATERIALIZED VIEW query, ALTER query, ALTER STREAM, ALTER DATABASE, RENAME query, RENAME STREAM, DROP query, DROP, DETACH, TRUNCATE, CHECK TABLE, KILL QUERY query, KILL, OPTIMIZE query, OPTIMIZE TABLE, WATCH query, WATCH, SHOW FORMAT SCHEMAS query, SHOW ACCESS query, SHOW ACCESS, ShowAccessEntitiesQuery, SHOW GRANTS query, SHOW GRANTS, SHOW PRIVILEGES query, SHOW PRIVILEGES, INSERT query, INSERT INTO, USE query, USE, SET ROLE or SET DEFAULT ROLE query, SET ROLE DEFAULT, SET ROLE, SET DEFAULT ROLE, SET query, SET, SYSTEM query, SYSTEM, CREATE USER or ALTER USER query, ALTER USER, CREATE USER, CREATE ROLE or ALTER ROLE query, ALTER ROLE, CREATE ROLE, CREATE QUOTA or ALTER QUOTA query, ALTER QUOTA, CREATE QUOTA, CREATE ROW POLICY or ALTER ROW POLICY query, CREATE SETTINGS PROFILE or ALTER SETTINGS PROFILE query, CREATE FUNCTION query, CREATE FORMAT SCHEMA query, DROP FORMAT SCHEMA query, DROP FUNCTION query, DROP access entity query, GRANT or REVOKE query, REVOKE, GRANT, EXTERNAL DDL query, EXTERNAL DDL FROM, TCL query, BEGIN TRANSACTION, COMMIT, ROLLBACK, SET TRANSACTION SNAPSHOT, BACKUP or RESTORE query, BACKUP, RESTORE. (SYNTAX_ERROR) (version 1.3.31)
Jan 13, 2024 4:19:33 AM com.timeplus.kafkaconnect.TimeplusSinkTask put
SEVERE: ingest to timeplus failed : message -> Bad Request
Jan 13, 2024 4:19:33 AM com.timeplus.kafkaconnect.TimeplusSinkTask put
SEVERE: ingest to timeplus failed : response -> Code: 62. DB::Exception: Syntax error: failed at position 1 ('{'): {"data":[["{\"server_id\":\"q22\",\"conidEx\":\"14016011\",\"conid\":14016011,\"_updated\":1704488599988,\"6119\":\"q22\",\"85\":\"300\",\"87\":\"254K\",\"87_ra. Expected one of: Query, Query with output, EXPLAIN, SELECT query, possibly with UNION, list of union elements, SELECT query, subquery, possibly with UNION, SELECT subquery, SELECT query, WITH, SELECT, SUBSCRIBE TO SELECT query, possibly with UNION, SUBSCRIBE, UNSUBSCRIBE FROM SELECT query, possibly with UNION SETTINGS query_id=uuid, UNSUBSCRIBE, RECOVER FROM SELECT query, possibly with UNION SETTINGS query_id=uuid, RECOVER, SHOW CREATE QUOTA query, SHOW CREATE, SHOW CREATE FORMAT SCHEMA query, SHOW, SHOW [TEMPORARY] TABLES|DATABASES|CLUSTERS|CLUSTER 'name' [[NOT] [I]LIKE 'str'] [LIMIT expr], EXISTS or SHOW CREATE query, EXISTS, DESCRIBE FILESYSTEM CACHE query, DESCRIBE, DESC, DESCRIBE query, SHOW PROCESSLIST query, SHOW PROCESSLIST, CREATE STREAM or ATTACH STREAM query, CREATE, ATTACH, CREATE DATABASE query, CREATE VIEW query, CREATE DICTIONARY, CREATE MATERIALIZED VIEW query, ALTER query, ALTER STREAM, ALTER DATABASE, RENAME query, RENAME STREAM, DROP query, DROP, DETACH, TRUNCATE, CHECK TABLE, KILL QUERY query, KILL, OPTIMIZE query, OPTIMIZE TABLE, WATCH query, WATCH, SHOW FORMAT SCHEMAS query, SHOW ACCESS query, SHOW ACCESS, ShowAccessEntitiesQuery, SHOW GRANTS query, SHOW GRANTS, SHOW PRIVILEGES query, SHOW PRIVILEGES, INSERT query, INSERT INTO, USE query, USE, SET ROLE or SET DEFAULT ROLE query, SET ROLE DEFAULT, SET ROLE, SET DEFAULT ROLE, SET query, SET, SYSTEM query, SYSTEM, CREATE USER or ALTER USER query, ALTER USER, CREATE USER, CREATE ROLE or ALTER ROLE query, ALTER ROLE, CREATE ROLE, CREATE QUOTA or ALTER QUOTA query, ALTER QUOTA, CREATE QUOTA, CREATE ROW POLICY or ALTER ROW POLICY query, CREATE SETTINGS PROFILE or ALTER SETTINGS PROFILE query, CREATE FUNCTION query, CREATE FORMAT SCHEMA query, DROP FORMAT SCHEMA query, DROP FUNCTION query, DROP access entity query, GRANT or REVOKE query, REVOKE, GRANT, EXTERNAL DDL query, EXTERNAL DDL FROM, TCL query, BEGIN TRANSACTION, COMMIT, ROLLBACK, SET TRANSACTION SNAPSHOT, BACKUP or RESTORE query, BACKUP, RESTORE. (SYNTAX_ERROR) (version 1.3.31)
Jan 13, 2024 4:19:33 AM com.timeplus.kafkaconnect.TimeplusSinkTask put
SEVERE: ingest to timeplus failed : payload -> {"data":[["{\"server_id\":\"q22\",\"conidEx\":\"14016011\",\"conid\":14016011,\"_updated\":1704488599988,\"6119\":\"q22\",\"85\":\"300\",\"87\":\"254K\",\"87_raw\":254000.0,\"86\":\"1863.0\",\"88\":\"100\",\"7295\":\"1825.0\",\"83\":0.0,\"31\":\"1854.0\",\"84\":\"1846.0\",\"7289\":\"85.477B\",\"7762\":\"253700\",\"7741\":\"1854.0\",\"6509\":\"ZB\",\"topic\":\"smd+14016011\"}"],["{\"server_id\":\"q36\",\"conidEx\":\"14016011\",\"conid\":14016011,\"_updated\":1704488939015,\"6119\":\"q36\",\"85\":\"300\",\"87\":\"254K\",\"87_raw\":254000.0,\"86\":\"1863.0\",\"88\":\"100\",\"7295\":\"1825.0\",\"83\":0.0,\"31\":\"1854.0\",\"84\":\"1846.0\",\"7762\":\"253700\",\"7741\":\"1854.0\",\"6509\":\"ZB\",\"topic\":\"smd+14016011\"}"],["{\"server_id\":\"q50\",\"conidEx\":\"14016011\",\"conid\":14016011,\"_updated\":1704492580220,\"6119\":\"q50\",\"7087\":\"28.111%\",\"85\":\"300\",\"87\":\"254K\",\"87_raw\":254000.0,\"86\":\"1863.0\",\"88\":\"100\",\"7295\":\"1825.0\",\"83\":0.0,\"31\":\"1854.0\",\"84\":\"1846.0\",\"7762\":\"253700\",\"7741\":\"1854.0\",\"6509\":\"ZB\",\"topic\":\"smd+14016011\"}"],["{\"server_id\":\"q64\",\"conidEx\":\"14016011\",\"conid\":14016011,\"_updated\":1704492803542,\"6119\":\"q64\",\"85\":\"300\",\"87\":\"254K\",\"87_raw\":254000.0,\"86\":\"1863.0\",\"88\":\"100\",\"7295\":\"1825.0\",\"83\":0.0,\"31\":\"1854.0\",\"84\":\"1846.0\",\"7762\":\"253700\",\"7741\":\"1854.0\",\"6509\":\"ZB\",\"topic\":\"smd+14016011\"}"],["{\"server_id\":\"q80\",\"conidEx\":\"14016916\",\"conid\":14016916,\"_updated\":1704492817880,\"6119\":\"q80\",\"7674\":\"1279.47\",\"7676\":\"1207.29\",\"7675\":\"1244.66\",\"85\":\"300\",\"87\":\"148K\",\"87_raw\":148000.0,\"86\":\"1231.0\",\"88\":\"300\",\"7677\":\"1186.86\",\"7295\":\"1246.0\",\"83\":0.0,\"31\":\"1225.0\",\"84\":\"1219.0\",\"7762\":\"148000\",\"7741\":\"1225.0\",\"6509\":\"ZB\",\"topic\":\"smd+14016916\"}"],["{\"server_id\":\"q119\",\"conidEx\":\"56984519\",\"conid\":56984519,\"_updated\":1704492817880,\"6119\":\"q119\",\"7674\":\"2544.13\",\"7676\":\"2730.48\",\"7675\":\"2681.34\",\"85\":\"100\",\"87\":\"238K\",\"87_raw\":238000.0,\"86\":\"2987.0\",\"88\":\"100\",\"7677\":\"2764.92\",\"7295\":\"2899.0\",\"83\":1.34,\"31\":\"2951.0\",\"84\":\"2984.0\",\"7762\":\"237900\",\"7741\":\"2912.0\",\"6509\":\"ZB\",\"topic\":\"smd+56984519\"}"],["{\"server_id\":\"q110\",\"conidEx\":\"316282030\",\"conid\":316282030,\"_updated\":1704492817880,\"6119\":\"q110\",\"7674\":\"1354.79\",\"7676\":\"1292.74\",\"7675\":\"1318.18\",\"85\":\"100\",\"87\":\"1.06M\",\"87_raw\":1060000.0,\"86\":\"1185.0\",\"88\":\"100\",\"7677\":\"1255.21\",\"7295\":\"1185.0\",\"83\":0.0,\"31\":\"1171.0\",\"84\":\"1171.0\",\"7762\":\"1063200\",\"7741\":\"1171.0\",\"6509\":\"ZB\",\"topic\":\"smd+316282030\"}"],["{\"server_id\":\"q75\",\"conidEx\":\"14015316\",\"conid\":14015316,\"_updated\":1704492818885,\"6119\":\"q75\",\"7674\":\"1356.86\",\"7676\":\"1628.54\",\"7675\":\"1505.98\",\"87\":\"57.2K\",\"87_raw\":57200.0,\"7677\":\"1750.50\",\"7295\":\"1898.0\",\"83\":0.0,\"31\":\"1909.0\",\"7762\":\"57200\",\"7741\":\"1909.0\",\"topic\":\"smd+14015316\"}"],["{\"server_id\":\"q114\",\"conidEx\":\"113787206\",\"conid\":113787206,\"_updated\":1704492818885,\"6119\":\"q114\",\"7674\":\"2791.00\",\"7676\":\"2810.44\",\"7675\":\"2826.59\",\"87\":\"4.20M\",\"87_raw\":4200000.0,\"7677\":\"2790.62\",\"7295\":\"2790.0\",\"83\":0.09,\"31\":\"2789.0\",\"7762\":\"4204200\",\"7741\":\"2786.5\",\"topic\":\"smd+113787206\"}"],["{\"server_id\":\"q98\",\"conidEx\":\"128713428\",\"conid\":128713428,\"_updated\":1704492818886,\"6119\":\"q98\",\"7674\":\"2394.48\",\"7676\":\"2298.96\",\"7675\":\"2347.04\",\"87\":\"271K\",\"87_raw\":271000.0,\"7677\":\"2302.42\",\"7295\":\"2364.5\",\"83\":0.0,\"31\":\"2328.5\",\"7762\":\"270600\",\"7741\":\"2328.5\",\"topic\":\"smd+128713428\"}"],["{\"server_id\":\"q135\",\"conidEx\":\"49939805\",\"conid\":49939805,\"_updated\":1704492818886,\"6119\":\"q135\",\"7674\":\"1582.26\",\"7676\":\"1634.39\",\"7675\":\"1593.59\",\"85\":\"100\",\"87\":\"138K\",\"87_raw\":138000.0,\"86\":\"1843.0\",\"88\":\"100\",\"7677\":\"1713.35\",\"7295\":\"1775.0\",\"83\":0.4,\"31\":\"1750.0\",\"84\":\"1721.0\",\"7762\":\"137800\",\"7741\":\"1743.0\",\"6509\":\"ZB\",\"topic\":\"smd+49939805\"}"],["{\"server_id\":\"q136\",\"conidEx\":\"14014836\",\"conid\":14014836,\"_updated\":1704492818886,\"6119\":\"q136\",\"7674\":\"2206.98\",\"7676\":\"2279.46\",\"7675\":\"2275.70\",\"87\":\"30.0K\",\"87_raw\":30000.0,\"7677\":\"2289.39\",\"7295\":\"2397.0\",\"83\":0.0,\"31\":\"2387.0\",\"7762\":\"30000\",\"7741\":\"2387.0\",\"6509\":\"ZB\",\"topic\":\"smd+14014836\"}"],["{\"server_id\":\"q155\",\"conidEx\":\"295291791\",\"conid\":295291791,\"_updated\":1704492818886,\"6119\":\"q155\",\"7674\":\"2041.69\",\"7676\":\"2057.60\",\"7675\":\"2048.22\",\"85\":\"100\",\"87\":\"1.01M\",\"87_raw\":1010000.0,\"86\":\"2070.0\",\"88\":\"300\",\"7677\":\"2055.09\",\"7295\":\"2096.0\",\"83\":0.15,\"31\":\"2070.0\",\"84\":\"2057.4\",\"7762\":\"1005500\",\"7741\":\"2067.0\",\"6509\":\"ZB\",\"topic\":\"smd+295291791\"}"],["{\"88\":\"100\",\"7087\":\"28.111%\",\"conidEx\":\"14016011\",\"7741\":\"1854.0\",\"7762\":\"253700\",\"7289\":\"85.477B\",\"7284\":\"28.111%\",\"6509\":\"ZB\",\"7636\":\"102,732\",\"31\":\"1854.0\",\"55\":\"5351\",\"7675\":\"1508.58\",\"7674\":\"1304.08\",\"7677\":\"1708.20\",\"7676\":\"1635.83\",\"_updated\":1704492817880,\"87_raw\":254000.0,\"server_id\":\"q64\",\"7295\":\"1825.0\",\"topic\":\"smd+14016011\",\"conid\":14016011,\"6119\":\"q64\",\"83\":0.0,\"84\":\"1846.0\",\"85\":\"300\",\"86\":\"1863.0\",\"87\":\"254K\"}"],["{\"88\":\"100\",\"7087\":\"31.319%\",\"conidEx\":\"14015316\",\"7741\":\"1909.0\",\"7289\":\"24.72B\",\"7762\":\"57200\",\"7284\":\"31.319%\",\"6509\":\"ZB\",\"7636\":\"19,833\",\"31\":\"1909.0\",\"55\":\"3877\",\"7675\":\"1505.98\",\"7674\":\"1356.86\",\"7677\":\"1750.50\",\"7676\":\"1628.54\",\"_updated\":1704492818885,\"87_raw\":57200.0,\"server_id\":\"q75\",\"7295\":\"1898.0\",\"topic\":\"smd+14015316\",\"conid\":14015316,\"6119\":\"q75\",\"83\":0.0,\"84\":\"1860.0\",\"85\":\"100\",\"86\":\"2100.0\",\"87\":\"57.2K\"}"],["{\"88\":\"300\",\"7087\":\"38.051%\",\"conidEx\":\"14016916\",\"7741\":\"1225.0\",\"7289\":\"29.026B\",\"7762\":\"148000\",\"7284\":\"38.051%\",\"6509\":\"ZB\",\"7636\":\"29,201\",\"31\":\"1225.0\",\"55\":\"6779\",\"7675\":\"1244.66\",\"7674\":\"1279.47\",\"7677\":\"1186.86\",\"7676\":\"1207.29\",\"_updated\":1704492817880,\"87_raw\":148000.0,\"server_id\":\"q80\",\"7295\":\"1246.0\",\"topic\":\"smd+14016916\",\"conid\":14016916,\"6119\":\"q80\",\"83\":0.0,\"84\":\"1219.0\",\"85\":\"300\",\"86\":\"1231.0\",\"87\":\"148K\"}"],["{\"88\":\"300\",\"7087\":\"21.973%\",\"conidEx\":\"128713428\",\"7741\":\"2328.5\",\"7289\":\"207.669B\",\"7762\":\"270600\",\"7284\":\"21.973%\",\"6509\":\"ZB\",\"7636\":\"480,156\",\"31\":\"2328.5\",\"55\":\"3765\",\"7675\":\"2347.04\",\"7674\":\"2394.48\",\"7677\":\"2302.42\",\"7676\":\"2298.96\",\"_updated\":1704492818886,\"87_raw\":271000.0,\"server_id\":\"q98\",\"7295\":\"2364.5\",\"topic\":\"smd+128713428\",\"conid\":128713428,\"6119\":\"q98\",\"83\":0.0,\"84\":\"2317.5\",\"85\":\"300\",\"86\":\"2339.5\",\"87\":\"271K\"}"],["{\"88\":\"100\",\"7087\":\"49.208%\",\"conidEx\":\"316282030\",\"7741\":\"1171.0\",\"7289\":\"72.38B\",\"7762\":\"1063200\",\"7284\":\"49.208%\",\"6509\":\"ZB\",\"31\":\"1171.0\",\"55\":\"4384\",\"7675\":\"1318.18\",\"7674\":\"1354.79\",\"7677\":\"1255.21\",\"7676\":\"1292.74\",\"_updated\":1704492817880,\"87_raw\":1060000.0,\"server_id\":\"q110\",\"7295\":\"1185.0\",\"topic\":\"smd+316282030\",\"conid\":316282030,\"6119\":\"q110\",\"83\":0.0,\"84\":\"1171.0\",\"85\":\"100\",\"86\":\"1185.0\",\"87\":\"1.06M\"}"],["{\"88\":\"100\",\"7087\":\"17.967%\",\"conidEx\":\"113787206\",\"7741\":\"2786.5\",\"7289\":\"1,222.472B\",\"7762\":\"4204200\",\"7284\":\"17.967%\",\"6509\":\"ZB\",\"7636\":\"926,110\",\"31\":\"2789.0\",\"55\":\"9201\",\"7675\":\"2826.59\",\"7674\":\"2791.00\",\"7677\":\"2790.62\",\"7676\":\"2810.44\",\"_updated\":1704492818885,\"87_raw\":4200000.0,\"server_id\":\"q114\",\"7295\":\"2790.0\",\"topic\":\"smd+113787206\",\"conid\":113787206,\"6119\":\"q114\",\"83\":0.09,\"84\":\"2786.1\",\"85\":\"400\",\"86\":\"2787.5\",\"87\":\"4.20M\"}"],["{\"88\":\"100\",\"7087\":\"25.560%\",\"conidEx\":\"56984519\",\"7741\":\"2912.0\",\"7289\":\"109.94B\",\"7762\":\"237900\",\"7284\":\"25.560%\",\"6509\":\"ZB\",\"31\":\"2951.0\",\"55\":\"7611\",\"7675\":\"2681.34\",\"7674\":\"2544.13\",\"7677\":\"2764.92\",\"7676\":\"2730.48\",\"_updated\":1704492817880,\"87_raw\":238000.0,\"server_id\":\"q119\",\"7295\":\"2899.0\",\"topic\":\"smd+56984519\",\"conid\":56984519,\"6119\":\"q119\",\"83\":1.34,\"84\":\"2984.0\",\"85\":\"100\",\"86\":\"2987.0\",\"87\":\"238K\"}"],["{\"88\":\"100\",\"7087\":\"53.588%\",\"conidEx\":\"49939805\",\"7741\":\"1743.0\",\"7289\":\"15.833B\",\"7762\":\"137800\",\"7284\":\"53.588%\",\"6509\":\"ZB\",\"31\":\"1750.0\",\"55\":\"6668\",\"7675\":\"1593.59\",\"7674\":\"1582.26\",\"7677\":\"1713.35\",\"7676\":\"1634.39\",\"_updated\":1704492818886,\"87_raw\":138000.0,\"server_id\":\"q135\",\"7295\":\"1775.0\",\"topic\":\"smd+49939805\",\"conid\":49939805,\"6119\":\"q135\",\"83\":0.4,\"84\":\"1721.0\",\"85\":\"100\",\"86\":\"1843.0\",\"87\":\"138K\"}"],["{\"55\":\"1952\",\"7087\":\"16.768%\",\"conidEx\":\"14014836\",\"7675\":\"2275.70\",\"7741\":\"2387.0\",\"7289\":\"58.496B\",\"7674\":\"2206.98\",\"7762\":\"30000\",\"7677\":\"2289.39\",\"7676\":\"2279.46\",\"_updated\":1704492818886,\"87_raw\":30000.0,\"server_id\":\"q136\",\"7284\":\"16.768%\",\"7295\":\"2397.0\",\"6509\":\"ZB\",\"topic\":\"smd+14014836\",\"conid\":14014836,\"6119\":\"q136\",\"7636\":\"23,855\",\"83\":0.0,\"31\":\"2387.0\",\"87\":\"30.0K\"}"],["{\"88\":\"300\",\"7087\":\"22.257%\",\"conidEx\":\"295291791\",\"7741\":\"2067.0\",\"7289\":\"1,348.35B\",\"7762\":\"1005500\",\"7284\":\"22.257%\",\"6509\":\"ZB\",\"7636\":\"1,951,823\",\"31\":\"2070.0\",\"55\":\"9143\",\"7675\":\"2048.22\",\"7674\":\"2041.69\",\"7677\":\"2055.09\",\"7676\":\"2057.60\",\"_updated\":1704492818886,\"87_raw\":1010000.0,\"server_id\":\"q155\",\"7295\":\"2096.0\",\"topic\":\"smd+295291791\",\"conid\":295291791,\"6119\":\"q155\",\"83\":0.15,\"84\":\"2057.4\",\"85\":\"100\",\"86\":\"2070.0\",\"87\":\"1.01M\"}"],["{\"server_id\":\"q199\",\"conidEx\":\"128713428\",\"conid\":128713428,\"_updated\":1704493885442,\"6119\":\"q199\",\"7636\":\"480,156\",\"7674\":\"2394.48\",\"7087\":\"21.973%\",\"7676\":\"2298.96\",\"7675\":\"2347.04\",\"85\":\"300\",\"7284\":\"21.973%\",\"87\":\"271K\",\"87_raw\":271000.0,\"86\":\"2339.5\",\"88\":\"300\",\"7677\":\"2302.42\",\"7295\":\"2364.5\",\"83\":0.0,\"31\":\"2328.5\",\"84\":\"2317.5\",\"7762\":\"270600\",\"7741\":\"2328.5\",\"6509\":\"ZB\",\"topic\":\"smd+128713428\"}"],["{\"server_id\":\"q176\",\"conidEx\":\"14015316\",\"conid\":14015316,\"_updated\":1704493885443,\"6119\":\"q176\",\"7636\":\"19,833\",\"7674\":\"1356.86\",\"7087\":\"31.319%\",\"7676\":\"1628.54\",\"7675\":\"1505.98\",\"85\":\"100\",\"7284\":\"31.319%\",\"87\":\"57.2K\",\"87_raw\":57200.0,\"86\":\"2100.0\",\"88\":\"100\",\"7677\":\"1750.50\",\"7295\":\"1898.0\",\"83\":0.0,\"31\":\"1909.0\",\"84\":\"1860.0\",\"7762\":\"57200\",\"7741\":\"1909.0\",\"6509\":\"ZB\",\"topic\":\"smd+14015316\"}"],["{\"server_id\":\"q165\",\"conidEx\":\"14016011\",\"conid\":14016011,\"_updated\":1704493885443,\"6119\":\"q165\",\"7636\":\"102,732\",\"7674\":\"1304.08\",\"7087\":\"28.111%\",\"7676\":\"1635.83\",\"7675\":\"1508.58\",\"85\":\"300\",\"7284\":\"28.111%\",\"87\":\"254K\",\"87_raw\":254000.0,\"86\":\"1863.0\",\"88\":\"100\",\"7677\":\"1708.20\",\"7295\":\"1825.0\",\"83\":0.0,\"31\":\"1854.0\",\"84\":\"1846.0\",\"7762\":\"253700\",\"7741\":\"1854.0\",\"6509\":\"ZB\",\"topic\":\"smd+14016011\"}"],["{\"server_id\":\"q181\",\"conidEx\":\"14016916\",\"conid\":14016916,\"_updated\":1704493885444,\"6119\":\"q181\",\"7636\":\"29,201\",\"7674\":\"1279.47\",\"7087\":\"38.051%\",\"7676\":\"1207.29\",\"7675\":\"1244.66\",\"85\":\"300\",\"7284\":\"38.051%\",\"87\":\"148K\",\"87_raw\":148000.0,\"86\":\"1231.0\",\"88\":\"300\",\"7677\":\"1186.86\",\"7295\":\"1246.0\",\"83\":0.0,\"31\":\"1225.0\",\"84\":\"1219.0\",\"7762\":\"148000\",\"7741\":\"1225.0\",\"6509\":\"ZB\",\"topic\":\"smd+14016916\"}"],["{\"server_id\":\"q215\",\"conidEx\":\"113787206\",\"conid\":113787206,\"_updated\":1704493885444,\"6119\":\"q215\",\"7636\":\"926,110\",\"7674\":\"2791.00\",\"7087\":\"17.967%\",\"7676\":\"2810.44\",\"7675\":\"2826.59\",\"85\":\"400\",\"7284\":\"17.967%\",\"87\":\"4.20M\",\"87_raw\":4200000.0,\"86\":\"2787.5\",\"88\":\"100\",\"7677\":\"2790.62\",\"7295\":\"2790.0\",\"83\":0.09,\"31\":\"2789.0\",\"84\":\"2786.1\",\"7762\":\"4204200\",\"7741\":\"2786.5\",\"6509\":\"ZB\",\"topic\":\"smd+113787206\"}"],["{\"server_id\":\"q211\",\"conidEx\":\"316282030\",\"conid\":316282030,\"_updated\":1704493885444,\"6119\":\"q211\",\"7674\":\"1354.79\",\"7087\":\"49.208%\",\"7676\":\"1292.74\",\"7675\":\"1318.18\",\"85\":\"100\",\"7284\":\"49.208%\",\"87\":\"1.06M\",\"87_raw\":1060000.0,\"86\":\"1185.0\",\"88\":\"100\",\"7677\":\"1255.21\",\"7295\":\"1185.0\",\"83\":0.0,\"31\":\"1171.0\",\"84\":\"1171.0\",\"7762\":\"1063200\",\"7741\":\"1171.0\",\"6509\":\"ZB\",\"topic\":\"smd+316282030\"}"],["{\"server_id\":\"q220\",\"conidEx\":\"56984519\",\"conid\":56984519,\"_updated\":1704493887500,\"6119\":\"q220\",\"7674\":\"2544.13\",\"7676\":\"2730.48\",\"7675\":\"2681.34\",\"85\":\"100\",\"87\":\"238K\",\"87_raw\":238000.0,\"86\":\"2987.0\",\"88\":\"100\",\"7677\":\"2764.92\",\"7295\":\"2899.0\",\"83\":1.34,\"31\":\"2951.0\",\"84\":\"2984.0\",\"7762\":\"237900\",\"7741\":\"2912.0\",\"6509\":\"ZB\",\"topic\":\"smd+56984519\"}"],["{\"server_id\":\"q236\",\"conidEx\":\"49939805\",\"conid\":49939805,\"_updated\":1704493888002,\"6119\":\"q236\",\"7674\":\"1582.26\",\"7676\":\"1634.39\",\"7675\":\"1593.59\",\"85\":\"100\",\"87\":\"138K\",\"87_raw\":138000.0,\"86\":\"1843.0\",\"88\":\"100\",\"7677\":\"1713.35\",\"7295\":\"1775.0\",\"83\":0.4,\"31\":\"1750.0\",\"84\":\"1721.0\",\"7762\":\"137800\",\"7741\":\"1743.0\",\"6509\":\"ZB\",\"topic\":\"smd+49939805\"}"],["{\"server_id\":\"q237\",\"conidEx\":\"14014836\",\"conid\":14014836,\"_updated\":1704493888002,\"6119\":\"q237\",\"7674\":\"2206.98\",\"7676\":\"2279.46\",\"7675\":\"2275.70\",\"87\":\"30.0K\",\"87_raw\":30000.0,\"7677\":\"2289.39\",\"7295\":\"2397.0\",\"83\":0.0,\"31\":\"2387.0\",\"7762\":\"30000\",\"7741\":\"2387.0\",\"6509\":\"ZB\",\"topic\":\"smd+14014836\"}"],["{\"server_id\":\"q256\",\"conidEx\":\"295291791\",\"conid\":295291791,\"_updated\":1704493888002,\"6119\":\"q256\",\"7674\":\"2041.69\",\"7676\":\"2057.60\",\"7675\":\"2048.22\",\"85\":\"100\",\"87\":\"1.01M\",\"87_raw\":1010000.0,\"86\":\"2070.0\",\"88\":\"300\",\"7677\":\"2055.09\",\"7295\":\"2096.0\",\"83\":0.15,\"31\":\"2070.0\",\"84\":\"2057.4\",\"7762\":\"1005500\",\"7741\":\"2067.0\",\"6509\":\"ZB\",\"topic\":\"smd+295291791\"}"],["{\"server_id\":\"q236\",\"conidEx\":\"49939805\",\"conid\":49939805,\"_updated\":1704494108831,\"6119\":\"q236\",\"85\":\"\",\"87\":\"\",\"87_raw\":-1.0,\"86\":\"\",\"88\":\"\",\"7295\":\"\",\"83\":\"\",\"31\":\"\",\"84\":\"\",\"7762\":\"\",\"7741\":\"\",\"topic\":\"smd+49939805\"}"],["{\"server_id\":\"q237\",\"conidEx\":\"14014836\",\"conid\":14014836,\"_updated\":1704494108831,\"6119\":\"q237\",\"87\":\"\",\"87_raw\":-1.0,\"7295\":\"\",\"83\":\"\",\"31\":\"\",\"7762\":\"\",\"7741\":\"\",\"topic\":\"smd+14014836\"}"],["{\"server_id\":\"q199\",\"conidEx\":\"128713428\",\"conid\":128713428,\"_updated\":1704494108831,\"6119\":\"q199\",\"85\":\"\",\"87\":\"\",\"87_raw\":-1.0,\"86\":\"\",\"88\":\"\",\"7295\":\"\",\"83\":\"\",\"31\":\"\",\"84\":\"\",\"7762\":\"\",\"7741\":\"\",\"topic\":\"smd+128713428\"}"],["{\"server_id\":\"q176\",\"conidEx\":\"14015316\",\"conid\":14015316,\"_updated\":1704494108831,\"6119\":\"q176\",\"85\":\"\",\"87\":\"\",\"87_raw\":-1.0,\"86\":\"\",\"88\":\"\",\"7295\":\"\",\"83\":\"\",\"31\":\"\",\"84\":\"\",\"7762\":\"\",\"7741\":\"\",\"topic\":\"smd+14015316\"}"],["{\"server_id\":\"q165\",\"conidEx\":\"14016011\",\"conid\":14016011,\"_updated\":1704494108832,\"6119\":\"q165\",\"85\":\"\",\"87\":\"\",\"87_raw\":-1.0,\"86\":\"\",\"88\":\"\",\"7295\":\"\",\"83\":\"\",\"31\":\"\",\"84\":\"\",\"7762\":\"\",\"7741\":\"\",\"topic\":\"smd+14016011\"}"],["{\"server_id\":\"q220\",\"conidEx\":\"56984519\",\"conid\":56984519,\"_updated\":1704494108833,\"6119\":\"q220\",\"85\":\"\",\"87\":\"\",\"87_raw\":-1.0,\"86\":\"\",\"88\":\"\",\"7295\":\"\",\"83\":\"\",\"31\":\"\",\"84\":\"\",\"7762\":\"\",\"7741\":\"\",\"topic\":\"smd+56984519\"}"],["{\"server_id\":\"q181\",\"conidEx\":\"14016916\",\"conid\":14016916,\"_updated\":1704494108833,\"6119\":\"q181\",\"85\":\"\",\"87\":\"\",\"87_raw\":-1.0,\"86\":\"\",\"88\":\"\",\"7295\":\"\",\"83\":\"\",\"31\":\"\",\"84\":\"\",\"7762\":\"\",\"7741\":\"\",\"topic\":\"smd+14016916\"}"],["{\"server_id\":\"q215\",\"conidEx\":\"113787206\",\"conid\":113787206,\"_updated\":1704494108833,\"6119\":\"q215\",\"85\":\"\",\"87\":\"\",\"87_raw\":-1.0,\"86\":\"\",\"88\":\"\",\"7295\":\"\",\"83\":\"\",\"31\":\"\",\"84\":\"\",\"7762\":\"\",\"7741\":\"\",\"topic\":\"smd+113787206\"}"],["{\"server_id\":\"q211\",\"conidEx\":\"316282030\",\"conid\":316282030,\"_updated\":1704494108833,\"6119\":\"q211\",\"85\":\"\",\"87\":\"\",\"87_raw\":-1.0,\"86\":\"\",\"88\":\"\",\"7295\":\"\",\"83\":\"\",\"31\":\"\",\"84\":\"\",\"7762\":\"\",\"7741\":\"\",\"topic\":\"smd+316282030\"}"],["{\"server_id\":\"q236\",\"conidEx\":\"49939805\",\"conid\":49939805,\"_updated\":1704494109335,\"6119\":\"q236\",\"85\":\"100\",\"87\":\"138K\",\"87_raw\":138000.0,\"86\":\"1843.0\",\"88\":\"100\",\"7295\":\"1775.0\",\"83\":0.4,\"31\":\"1750.0\",\"84\":\"1721.0\",\"7762\":\"137800\",\"7741\":\"1743.0\",\"topic\":\"smd+49939805\"}"],["{\"server_id\":\"q237\",\"conidEx\":\"14014836\",\"conid\":14014836,\"_updated\":1704494109335,\"6119\":\"q237\",\"87\":\"30.0K\",\"87_raw\":30000.0,\"7295\":\"2397.0\",\"83\":0.0,\"31\":\"2387.0\",\"7762\":\"30000\",\"7741\":\"2387.0\",\"topic\":\"smd+14014836\"}"],["{\"server_id\":\"q199\",\"conidEx\":\"128713428\",\"conid\":128713428,\"_updated\":1704494109335,\"6119\":\"q199\",\"85\":\"300\",\"87\":\"271K\",\"87_raw\":271000.0,\"86\":\"2339.5\",\"88\":\"300\",\"7295\":\"2364.5\",\"83\":0.0,\"31\":\"2328.5\",\"84\":\"2317.5\",\"7762\":\"270600\",\"7741\":\"2328.5\",\"topic\":\"smd+128713428\"}"],["{\"server_id\":\"q176\",\"conidEx\":\"14015316\",\"conid\":14015316,\"_updated\":1704494109336,\"6119\":\"q176\",\"85\":\"100\",\"87\":\"57.2K\",\"87_raw\":57200.0,\"86\":\"2100.0\",\"88\":\"100\",\"7295\":\"1898.0\",\"83\":0.0,\"31\":\"1909.0\",\"84\":\"1860.0\",\"7762\":\"57200\",\"7741\":\"1909.0\",\"topic\":\"smd+14015316\"}"],["{\"server_id\":\"q165\",\"conidEx\":\"14016011\",\"conid\":14016011,\"_updated\":1704494109336,\"6119\":\"q165\",\"85\":\"300\",\"87\":\"254K\",\"87_raw\":254000.0,\"86\":\"1863.0\",\"88\":\"100\",\"7295\":\"1825.0\",\"83\":0.0,\"31\":\"1854.0\",\"84\":\"1846.0\",\"7762\":\"253700\",\"7741\":\"1854.0\",\"topic\":\"smd+14016011\"}"],["{\"server_id\":\"q220\",\"conidEx\":\"56984519\",\"conid\":56984519,\"_updated\":1704494109336,\"6119\":\"q220\",\"85\":\"100\",\"87\":\"238K\",\"87_raw\":238000.0,\"86\":\"2987.0\",\"88\":\"100\",\"7295\":\"2899.0\",\"83\":1.34,\"31\":\"2951.0\",\"84\":\"2984.0\",\"7762\":\"237900\",\"7741\":\"2912.0\",\"topic\":\"smd+56984519\"}"],["{\"server_id\":\"q181\",\"conidEx\":\"14016916\",\"conid\":14016916,\"_updated\":1704494109336,\"6119\":\"q181\",\"85\":\"300\",\"87\":\"148K\",\"87_raw\":148000.0,\"86\":\"1231.0\",\"88\":\"300\",\"7295\":\"1246.0\",\"83\":0.0,\"31\":\"1225.0\",\"84\":\"1219.0\",\"7762\":\"148000\",\"7741\":\"1225.0\",\"topic\":\"smd+14016916\"}"],["{\"server_id\":\"q215\",\"conidEx\":\"113787206\",\"conid\":113787206,\"_updated\":1704494109336,\"6119\":\"q215\",\"85\":\"400\",\"87\":\"4.20M\",\"87_raw\":4200000.0,\"86\":\"2787.5\",\"88\":\"100\",\"7295\":\"2790.0\",\"83\":0.09,\"31\":\"2789.0\",\"84\":\"2786.1\",\"7762\":\"4204200\",\"7741\":\"2786.5\",\"topic\":\"smd+113787206\"}"],["{\"server_id\":\"q211\",\"conidEx\":\"316282030\",\"conid\":316282030,\"_updated\":1704494109337,\"6119\":\"q211\",\"85\":\"100\",\"87\":\"1.06M\",\"87_raw\":1060000.0,\"86\":\"1185.0\",\"88\":\"100\",\"7295\":\"1185.0\",\"83\":0.0,\"31\":\"1171.0\",\"84\":\"1171.0\",\"7762\":\"1063200\",\"7741\":\"1171.0\",\"topic\":\"smd+316282030\"}"],["{\"server_id\":\"q265\",\"conidEx\":\"14016011\",\"conid\":14016011,\"_updated\":1704496357785,\"6119\":\"q265\",\"7087\":\"28.111%\",\"85\":\"300\",\"87\":\"254K\",\"87_raw\":254000.0,\"86\":\"1863.0\",\"88\":\"100\",\"7295\":\"1825.0\",\"83\":0.0,\"31\":\"1854.0\",\"84\":\"1846.0\",\"7762\":\"253700\",\"7741\":\"1854.0\",\"6509\":\"ZB\",\"topic\":\"smd+14016011\"}"],["{\"server_id\":\"q20\",\"conidEx\":\"14016011\",\"conid\":14016011,\"_updated\":1704758444340,\"6119\":\"q20\",\"88\":\"100\",\"7295\":\"1874.0\",\"86\":\"1882.0\",\"7741\":\"1854.0\",\"7762\":\"19800\",\"31\":\"1881.0\",\"83\":1.46,\"84\":\"1878.0\",\"87\":\"19.8K\",\"87_raw\":19800.0,\"85\":\"100\",\"6509\":\"RB\",\"topic\":\"smd+14016011\"}"],["{\"server_id\":\"q31\",\"conidEx\":\"14015316\",\"conid\":14015316,\"_updated\":1704758444530,\"6119\":\"q31\",\"88\":\"100\",\"7295\":\"1925.0\",\"86\":\"1930.0\",\"7741\":\"1909.0\",\"7762\":\"8900\",\"31\":\"1929.0\",\"83\":1.05,\"84\":\"1924.0\",\"87\":\"8.90K\",\"87_raw\":8900.0,\"85\":\"1,000\",\"6509\":\"RB\",\"topic\":\"smd+14015316\"}"],["{\"server_id\":\"q70\",\"conidEx\":\"113787206\",\"conid\":113787206,\"_updated\":1704758445151,\"6119\":\"q70\",\"7289\":\"1,218.1B\",\"88\":\"1,000\",\"7295\":\"2806.5\",\"86\":\"2804.5\",\"7741\":\"2786.5\",\"7762\":\"178300\",\"31\":\"2803.5\",\"83\":0.61,\"84\":\"2803.0\",\"87\":\"178K\",\"87_raw\":178000.0,\"85\":\"500\",\"6509\":\"RB\",\"topic\":\"smd+113787206\"}"],["{\"server_id\":\"q75\",\"conidEx\":\"56984519\",\"conid\":56984519,\"_updated\":1704758445151,\"6119\":\"q75\",\"88\":\"400\",\"7295\":\"2922.0\",\"86\":\"2949.0\",\"7741\":\"2912.0\",\"7762\":\"51400\",\"31\":\"2942.0\",\"83\":1.03,\"84\":\"2939.0\",\"87\":\"51.4K\",\"87_raw\":51400.0,\"85\":\"100\",\"6509\":\"RB\",\"topic\":\"smd+56984519\"}"],["{\"server_id\":\"q70\",\"conidEx\":\"113787206\",\"conid\":113787206,\"_updated\":1704758448896,\"6119\":\"q70\",\"7677\":\"2791.72\",\"88\":\"500\",\"86\":\"2804.0\",\"7762\":\"178400\",\"7676\":\"2810.10\",\"31\":\"2804.5\",\"7675\":\"2826.10\",\"83\":0.65,\"7674\":\"2791.08\",\"topic\":\"smd+113787206\"}"],["{\"server_id\":\"q75\",\"conidEx\":\"56984519\",\"conid\":56984519,\"_updated\":1704758448896,\"6119\":\"q75\",\"7677\":\"2778.14\",\"88\":\"300\",\"7762\":\"51600\",\"7676\":\"2737.20\",\"31\":\"2939.0\",\"7675\":\"2685.67\",\"83\":0.93,\"87\":\"51.6K\",\"87_raw\":51600.0,\"7674\":\"2547.69\",\"topic\":\"smd+56984519\"}"],["{\"server_id\":\"q111\",\"conidEx\":\"295291791\",\"conid\":295291791,\"_updated\":1704758448897,\"6119\":\"q111\",\"7677\":\"2056.55\",\"88\":\"100\",\"7295\":\"2079.0\",\"86\":\"2074.0\",\"7741\":\"2067.0\",\"7762\":\"28800\",\"7676\":\"2058.12\",\"31\":\"2073.5\",\"7675\":\"2048.63\",\"83\":0.31,\"84\":\"2072.5\",\"87\":\"28.8K\",\"87_raw\":28800.0,\"7674\":\"2041.99\",\"85\":\"100\",\"6509\":\"RB\",\"topic\":\"smd+295291791\"}"],["{\"server_id\":\"q92\",\"conidEx\":\"14014836\",\"conid\":14014836,\"_updated\":1704758448897,\"6119\":\"q92\",\"7677\":\"2301.54\",\"88\":\"300\",\"7295\":\"2419.0\",\"86\":\"2418.0\",\"7741\":\"2387.0\",\"7762\":\"1800\",\"7676\":\"2284.85\",\"31\":\"2417.0\",\"7675\":\"2278.49\",\"83\":1.26,\"84\":\"2399.0\",\"87\":\"1.80K\",\"87_raw\":1800.0,\"7674\":\"2209.11\",\"85\":\"200\",\"6509\":\"RB\",\"topic\":\"smd+14014836\"}"],["{\"server_id\":\"q36\",\"conidEx
Jan 13, 2024 4:19:33 AM com.timeplus.kafkaconnect.TimeplusSinkTask put
SEVERE: ingest to timeplus failed : message -> Bad Request
Jan 13, 2024 4:19:33 AM com.timeplus.kafkaconnect.TimeplusSinkTask put
SEVERE: ingest to timeplus failed : response -> Code: 62. DB::Exception: Syntax error: failed at position 1 ('{'): {"data":[["{\"server_id\":\"q70\",\"conidEx\":\"113787206\",\"conid\":113787206,\"_updated\":1704758790596,\"6119\":\"q70\",\"7677\":\"2793.06\",\"88\":\"1,800\. Expected one of: Query, Query with output, EXPLAIN, SELECT query, possibly with UNION, list of union elements, SELECT query, subquery, possibly with UNION, SELECT subquery, SELECT query, WITH, SELECT, SUBSCRIBE TO SELECT query, possibly with UNION, SUBSCRIBE, UNSUBSCRIBE FROM SELECT query, possibly with UNION SETTINGS query_id=uuid, UNSUBSCRIBE, RECOVER FROM SELECT query, possibly with UNION SETTINGS query_id=uuid, RECOVER, SHOW CREATE QUOTA query, SHOW CREATE, SHOW CREATE FORMAT SCHEMA query, SHOW, SHOW [TEMPORARY] TABLES|DATABASES|CLUSTERS|CLUSTER 'name' [[NOT] [I]LIKE 'str'] [LIMIT expr], EXISTS or SHOW CREATE query, EXISTS, DESCRIBE FILESYSTEM CACHE query, DESCRIBE, DESC, DESCRIBE query, SHOW PROCESSLIST query, SHOW PROCESSLIST, CREATE STREAM or ATTACH STREAM query, CREATE, ATTACH, CREATE DATABASE query, CREATE VIEW query, CREATE DICTIONARY, CREATE MATERIALIZED VIEW query, ALTER query, ALTER STREAM, ALTER DATABASE, RENAME query, RENAME STREAM, DROP query, DROP, DETACH, TRUNCATE, CHECK TABLE, KILL QUERY query, KILL, OPTIMIZE query, OPTIMIZE TABLE, WATCH query, WATCH, SHOW FORMAT SCHEMAS query, SHOW ACCESS query, SHOW ACCESS, ShowAccessEntitiesQuery, SHOW GRANTS query, SHOW GRANTS, SHOW PRIVILEGES query, SHOW PRIVILEGES, INSERT query, INSERT INTO, USE query, USE, SET ROLE or SET DEFAULT ROLE query, SET ROLE DEFAULT, SET ROLE, SET DEFAULT ROLE, SET query, SET, SYSTEM query, SYSTEM, CREATE USER or ALTER USER query, ALTER USER, CREATE USER, CREATE ROLE or ALTER ROLE query, ALTER ROLE, CREATE ROLE, CREATE QUOTA or ALTER QUOTA query, ALTER QUOTA, CREATE QUOTA, CREATE ROW POLICY or ALTER ROW POLICY query, CREATE SETTINGS PROFILE or ALTER SETTINGS PROFILE query, CREATE FUNCTION query, CREATE FORMAT SCHEMA query, DROP FORMAT SCHEMA query, DROP FUNCTION query, DROP access entity query, GRANT or REVOKE query, REVOKE, GRANT, EXTERNAL DDL query, EXTERNAL DDL FROM, TCL query, BEGIN TRANSACTION, COMMIT, ROLLBACK, SET TRANSACTION SNAPSHOT, BACKUP or RESTORE query, BACKUP, RESTORE. (SYNTAX_ERROR) (version 1.3.31)
Jan 13, 2024 4:19:33 AM com.timeplus.kafkaconnect.TimeplusSinkTask put
SEVERE: ingest to timeplus failed : payload -> {"data":[["{\"server_id\":\"q70\",\"conidEx\":\"113787206\",\"conid\":113787206,\"_updated\":1704758790596,\"6119\":\"q70\",\"7677\":\"2793.06\",\"88\":\"1,800\",\"7762\":\"413200\",\"7676\":\"2810.65\",\"31\":\"2818.5\",\"7675\":\"2826.38\",\"83\":1.15,\"7674\":\"2791.22\",\"topic\":\"smd+113787206\"}"],["{\"server_id\":\"q70\",\"conidEx\":\"113787206\",\"conid\":113787206,\"_updated\":1704758791598,\"6119\":\"q70\",\"7677\":\"2793.15\",\"7762\":\"413500\",\"7676\":\"2810.69\",\"31\":\"2819.5\",\"7675\":\"2826.40\",\"83\":1.18,\"87\":\"414K\",\"87_raw\":414000.0,\"7674\":\"2791.23\",\"85\":\"1,000\",\"topic\":\"smd+113787206\"}"],["{
Jan 13, 2024 4:19:33 AM com.timeplus.kafkaconnect.TimeplusSinkTask put
SEVERE: ingest to timeplus failed : message -> Bad Request
gangtao commented 10 months ago

@neodino I just merged the change, you can try make docker and then make proton_it on main branch to test your local connector. in your case, did you build your own image based that PR? what is the image you are using.

neodino commented 7 months ago

@neodino I just merged the change, you can try make docker and then make proton_it on main branch to test your local connector. in your case, did you build your own image based that PR? what is the image you are using.

@gantao I'm Im using strimzi connect cluster ( image is FROM quay.io/strimzi/kafka:0.39.0-kafka-3.6.1 ). Im using main branch now `` make one_jar
mvn clean compile assembly:single [INFO] Scanning for projects... [INFO] [INFO] ------< com.timeplus.kafkaconnect:kafka-timeplus-connector-sink >------- [INFO] Building kafka-timeplus-connector-sink 1.0.5 [INFO] --------------------------------[ jar ]--------------------------------- [INFO] [INFO] --- maven-clean-plugin:2.5:clean (default-clean) @ kafka-timeplus-connector-sink --- [INFO] [INFO] --- maven-enforcer-plugin:3.0.0-M3:enforce (default) @ kafka-timeplus-connector-sink --- [INFO] [INFO] --- jacoco-maven-plugin:0.8.8:prepare-agent (pre-unit-test) @ kafka-timeplus-connector-sink --- [INFO] argLine set to -javaagent:/.m2/repository/org/jacoco/org.jacoco.agent/0.8.8/org.jacoco.agent-0.8.8-runtime.jar=destfile=/.git/kafka-connect-timeplus/target/jacoco.exec [INFO] [INFO] --- maven-resources-plugin:2.6:resources (default-resources) @ kafka-timeplus-connector-sink --- [INFO] Using 'UTF-8' encoding to copy filtered resources. [INFO] skip non existing resourceDirectory /.git/kafka-connect-timeplus/src/main/resources [INFO] [INFO] --- maven-compiler-plugin:3.1:compile (default-compile) @ kafka-timeplus-connector-sink --- [INFO] Changes detected - recompiling the module! [INFO] Compiling 3 source files to /.git/kafka-connect-timeplus/target/classes [INFO] [INFO] --- maven-assembly-plugin:2.2-beta-5:single (default-cli) @ kafka-timeplus-connector-sink --- [INFO] META-INF/ already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/ already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/okio.kotlin_module already added, skipping [INFO] okio/ already added, skipping [INFO] okio/internal/ already added, skipping [INFO] META-INF/ already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/ already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/versions/ already added, skipping [INFO] META-INF/versions/9/ already added, skipping [INFO] META-INF/versions/9/module-info.class already added, skipping [INFO] META-INF/ already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] kotlin/ already added, skipping [INFO] kotlin/collections/ already added, skipping [INFO] kotlin/comparisons/ already added, skipping [INFO] kotlin/concurrent/ already added, skipping [INFO] kotlin/contracts/ already added, skipping [INFO] kotlin/coroutines/ already added, skipping [INFO] kotlin/coroutines/cancellation/ already added, skipping [INFO] kotlin/coroutines/intrinsics/ already added, skipping [INFO] kotlin/enums/ already added, skipping [INFO] kotlin/experimental/ already added, skipping [INFO] kotlin/internal/ already added, skipping [INFO] kotlin/io/ already added, skipping [INFO] kotlin/io/encoding/ already added, skipping [INFO] kotlin/js/ already added, skipping [INFO] kotlin/jvm/ already added, skipping [INFO] kotlin/math/ already added, skipping [INFO] kotlin/properties/ already added, skipping [INFO] kotlin/random/ already added, skipping [INFO] kotlin/ranges/ already added, skipping [INFO] kotlin/reflect/ already added, skipping [INFO] kotlin/sequences/ already added, skipping [INFO] kotlin/text/ already added, skipping [INFO] kotlin/time/ already added, skipping [INFO] META-INF/ already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/ already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/versions/ already added, skipping [INFO] META-INF/versions/9/ already added, skipping [INFO] META-INF/versions/9/module-info.class already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/ already added, skipping [INFO] META-INF/maven/ already added, skipping [INFO] META-INF/versions/ already added, skipping [INFO] META-INF/versions/9/ already added, skipping [INFO] META-INF/versions/9/module-info.class already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/ already added, skipping [INFO] dev/ already added, skipping [INFO] dev/failsafe/ already added, skipping [INFO] META-INF/maven/ already added, skipping [INFO] META-INF/maven/dev.failsafe/ already added, skipping [INFO] META-INF/versions/ already added, skipping [INFO] META-INF/versions/9/ already added, skipping [INFO] META-INF/versions/9/module-info.class already added, skipping [INFO] META-INF/ already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/maven/ already added, skipping [INFO] org/ already added, skipping [INFO] Building jar: /.git/kafka-connect-timeplus/target/kafka-timeplus-connector-sink-1.0.5.jar [INFO] META-INF/ already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/ already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/okio.kotlin_module already added, skipping [INFO] okio/ already added, skipping [INFO] okio/internal/ already added, skipping [INFO] META-INF/ already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/ already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/versions/ already added, skipping [INFO] META-INF/versions/9/ already added, skipping [INFO] META-INF/versions/9/module-info.class already added, skipping [INFO] META-INF/ already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] kotlin/ already added, skipping [INFO] kotlin/collections/ already added, skipping [INFO] kotlin/comparisons/ already added, skipping [INFO] kotlin/concurrent/ already added, skipping [INFO] kotlin/contracts/ already added, skipping [INFO] kotlin/coroutines/ already added, skipping [INFO] kotlin/coroutines/cancellation/ already added, skipping [INFO] kotlin/coroutines/intrinsics/ already added, skipping [INFO] kotlin/enums/ already added, skipping [INFO] kotlin/experimental/ already added, skipping [INFO] kotlin/internal/ already added, skipping [INFO] kotlin/io/ already added, skipping [INFO] kotlin/io/encoding/ already added, skipping [INFO] kotlin/js/ already added, skipping [INFO] kotlin/jvm/ already added, skipping [INFO] kotlin/math/ already added, skipping [INFO] kotlin/properties/ already added, skipping [INFO] kotlin/random/ already added, skipping [INFO] kotlin/ranges/ already added, skipping [INFO] kotlin/reflect/ already added, skipping [INFO] kotlin/sequences/ already added, skipping [INFO] kotlin/text/ already added, skipping [INFO] kotlin/time/ already added, skipping [INFO] META-INF/ already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/ already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/versions/ already added, skipping [INFO] META-INF/versions/9/ already added, skipping [INFO] META-INF/versions/9/module-info.class already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/ already added, skipping [INFO] META-INF/maven/ already added, skipping [INFO] META-INF/versions/ already added, skipping [INFO] META-INF/versions/9/ already added, skipping [INFO] META-INF/versions/9/module-info.class already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/ already added, skipping [INFO] dev/ already added, skipping [INFO] dev/failsafe/ already added, skipping [INFO] META-INF/maven/ already added, skipping [INFO] META-INF/maven/dev.failsafe/ already added, skipping [INFO] META-INF/versions/ already added, skipping [INFO] META-INF/versions/9/ already added, skipping [INFO] META-INF/versions/9/module-info.class already added, skipping [INFO] META-INF/ already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/maven/ already added, skipping [INFO] org/ already added, skipping [WARNING] Configuration options: 'appendAssemblyId' is set to false, and 'classifier' is missing. Instead of attaching the assembly file: /.git/kafka-connect-timeplus/target/kafka-timeplus-connector-sink-1.0.5.jar, it will become the file for main project artifact. NOTE: If multiple descriptors or descriptor-formats are provided for this project, the value of this file will be non-deterministic! [WARNING] Replacing pre-existing project main-artifact file: /.git/kafka-connect-timeplus/target/classes with assembly file: /.git/kafka-connect-timeplus/target/kafka-timeplus-connector-sink-1.0.5.jar [INFO] ------------------------------------------------------------------------ [INFO] BUILD SUCCESS [INFO] ------------------------------------------------------------------------ [INFO] Total time: 6.984 s [INFO] Finished at: 2024-04-15T07:37:05+10:00 [INFO] ------------------------------------------------------------------------

Then I use this jar file to install it ##############################

##############################

# This file is automatically generated by the Strimzi Cluster Operator

# Any changes to this file will be ignored and overwritten!

##############################

##############################

FROM quay.io/strimzi/kafka:0.39.0-kafka-3.6.1

USER root:root

##########

##########

# Connector plugin connect-timeplus-proton-sink-connector

##########

RUN 'mkdir' '-p'
'/opt/kafka/plugins/connect-timeplus-proton-sink-connector/a7b3eb29' \
      && 'curl' '-f' '-L' '--output' '/opt/kafka/plugins/connect-timeplus-proton-sink-connector/a7b3eb29/a7b3eb29.jar' 'https://*****/generic/connect_timeplus/1.0.5/kafka-timeplus-connector-sink-1.0.5.jar'

``

This still gives me error same error as above . Any idea?

gangtao commented 6 months ago

@neodino I just merged the change, you can try make docker and then make proton_it on main branch to test your local connector. in your case, did you build your own image based that PR? what is the image you are using.

@gantao I'm Im using strimzi connect cluster ( image is FROM quay.io/strimzi/kafka:0.39.0-kafka-3.6.1 ). Im using main branch now `` make one_jar mvn clean compile assembly:single [INFO] Scanning for projects... [INFO] [INFO] ------< com.timeplus.kafkaconnect:kafka-timeplus-connector-sink >------- [INFO] Building kafka-timeplus-connector-sink 1.0.5 [INFO] --------------------------------[ jar ]--------------------------------- [INFO] [INFO] --- maven-clean-plugin:2.5:clean (default-clean) @ kafka-timeplus-connector-sink --- [INFO] [INFO] --- maven-enforcer-plugin:3.0.0-M3:enforce (default) @ kafka-timeplus-connector-sink --- [INFO] [INFO] --- jacoco-maven-plugin:0.8.8:prepare-agent (pre-unit-test) @ kafka-timeplus-connector-sink --- [INFO] argLine set to -javaagent:/.m2/repository/org/jacoco/org.jacoco.agent/0.8.8/org.jacoco.agent-0.8.8-runtime.jar=destfile=/.git/kafka-connect-timeplus/target/jacoco.exec [INFO] [INFO] --- maven-resources-plugin:2.6:resources (default-resources) @ kafka-timeplus-connector-sink --- [INFO] Using 'UTF-8' encoding to copy filtered resources. [INFO] skip non existing resourceDirectory /.git/kafka-connect-timeplus/src/main/resources [INFO] [INFO] --- maven-compiler-plugin:3.1:compile (default-compile) @ kafka-timeplus-connector-sink --- [INFO] Changes detected - recompiling the module! [INFO] Compiling 3 source files to /.git/kafka-connect-timeplus/target/classes [INFO] [INFO] --- maven-assembly-plugin:2.2-beta-5:single (default-cli) @ kafka-timeplus-connector-sink --- [INFO] META-INF/ already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/ already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/okio.kotlin_module already added, skipping [INFO] okio/ already added, skipping [INFO] okio/internal/ already added, skipping [INFO] META-INF/ already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/ already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/versions/ already added, skipping [INFO] META-INF/versions/9/ already added, skipping [INFO] META-INF/versions/9/module-info.class already added, skipping [INFO] META-INF/ already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] kotlin/ already added, skipping [INFO] kotlin/collections/ already added, skipping [INFO] kotlin/comparisons/ already added, skipping [INFO] kotlin/concurrent/ already added, skipping [INFO] kotlin/contracts/ already added, skipping [INFO] kotlin/coroutines/ already added, skipping [INFO] kotlin/coroutines/cancellation/ already added, skipping [INFO] kotlin/coroutines/intrinsics/ already added, skipping [INFO] kotlin/enums/ already added, skipping [INFO] kotlin/experimental/ already added, skipping [INFO] kotlin/internal/ already added, skipping [INFO] kotlin/io/ already added, skipping [INFO] kotlin/io/encoding/ already added, skipping [INFO] kotlin/js/ already added, skipping [INFO] kotlin/jvm/ already added, skipping [INFO] kotlin/math/ already added, skipping [INFO] kotlin/properties/ already added, skipping [INFO] kotlin/random/ already added, skipping [INFO] kotlin/ranges/ already added, skipping [INFO] kotlin/reflect/ already added, skipping [INFO] kotlin/sequences/ already added, skipping [INFO] kotlin/text/ already added, skipping [INFO] kotlin/time/ already added, skipping [INFO] META-INF/ already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/ already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/versions/ already added, skipping [INFO] META-INF/versions/9/ already added, skipping [INFO] META-INF/versions/9/module-info.class already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/ already added, skipping [INFO] META-INF/maven/ already added, skipping [INFO] META-INF/versions/ already added, skipping [INFO] META-INF/versions/9/ already added, skipping [INFO] META-INF/versions/9/module-info.class already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/ already added, skipping [INFO] dev/ already added, skipping [INFO] dev/failsafe/ already added, skipping [INFO] META-INF/maven/ already added, skipping [INFO] META-INF/maven/dev.failsafe/ already added, skipping [INFO] META-INF/versions/ already added, skipping [INFO] META-INF/versions/9/ already added, skipping [INFO] META-INF/versions/9/module-info.class already added, skipping [INFO] META-INF/ already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/maven/ already added, skipping [INFO] org/ already added, skipping [INFO] Building jar: /.git/kafka-connect-timeplus/target/kafka-timeplus-connector-sink-1.0.5.jar [INFO] META-INF/ already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/ already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/okio.kotlin_module already added, skipping [INFO] okio/ already added, skipping [INFO] okio/internal/ already added, skipping [INFO] META-INF/ already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/ already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/versions/ already added, skipping [INFO] META-INF/versions/9/ already added, skipping [INFO] META-INF/versions/9/module-info.class already added, skipping [INFO] META-INF/ already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] kotlin/ already added, skipping [INFO] kotlin/collections/ already added, skipping [INFO] kotlin/comparisons/ already added, skipping [INFO] kotlin/concurrent/ already added, skipping [INFO] kotlin/contracts/ already added, skipping [INFO] kotlin/coroutines/ already added, skipping [INFO] kotlin/coroutines/cancellation/ already added, skipping [INFO] kotlin/coroutines/intrinsics/ already added, skipping [INFO] kotlin/enums/ already added, skipping [INFO] kotlin/experimental/ already added, skipping [INFO] kotlin/internal/ already added, skipping [INFO] kotlin/io/ already added, skipping [INFO] kotlin/io/encoding/ already added, skipping [INFO] kotlin/js/ already added, skipping [INFO] kotlin/jvm/ already added, skipping [INFO] kotlin/math/ already added, skipping [INFO] kotlin/properties/ already added, skipping [INFO] kotlin/random/ already added, skipping [INFO] kotlin/ranges/ already added, skipping [INFO] kotlin/reflect/ already added, skipping [INFO] kotlin/sequences/ already added, skipping [INFO] kotlin/text/ already added, skipping [INFO] kotlin/time/ already added, skipping [INFO] META-INF/ already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/ already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/versions/ already added, skipping [INFO] META-INF/versions/9/ already added, skipping [INFO] META-INF/versions/9/module-info.class already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/ already added, skipping [INFO] META-INF/maven/ already added, skipping [INFO] META-INF/versions/ already added, skipping [INFO] META-INF/versions/9/ already added, skipping [INFO] META-INF/versions/9/module-info.class already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/ already added, skipping [INFO] dev/ already added, skipping [INFO] dev/failsafe/ already added, skipping [INFO] META-INF/maven/ already added, skipping [INFO] META-INF/maven/dev.failsafe/ already added, skipping [INFO] META-INF/versions/ already added, skipping [INFO] META-INF/versions/9/ already added, skipping [INFO] META-INF/versions/9/module-info.class already added, skipping [INFO] META-INF/ already added, skipping [INFO] META-INF/MANIFEST.MF already added, skipping [INFO] META-INF/maven/ already added, skipping [INFO] org/ already added, skipping [WARNING] Configuration options: 'appendAssemblyId' is set to false, and 'classifier' is missing. Instead of attaching the assembly file: /.git/kafka-connect-timeplus/target/kafka-timeplus-connector-sink-1.0.5.jar, it will become the file for main project artifact. NOTE: If multiple descriptors or descriptor-formats are provided for this project, the value of this file will be non-deterministic! [WARNING] Replacing pre-existing project main-artifact file: /.git/kafka-connect-timeplus/target/classes with assembly file: /.git/kafka-connect-timeplus/target/kafka-timeplus-connector-sink-1.0.5.jar [INFO] ------------------------------------------------------------------------ [INFO] BUILD SUCCESS [INFO] ------------------------------------------------------------------------ [INFO] Total time: 6.984 s [INFO] Finished at: 2024-04-15T07:37:05+10:00 [INFO] ------------------------------------------------------------------------

Then I use this jar file to install it ##############################

##############################

# This file is automatically generated by the Strimzi Cluster Operator

# Any changes to this file will be ignored and overwritten!

##############################

##############################

FROM quay.io/strimzi/kafka:0.39.0-kafka-3.6.1

USER root:root

##########

##########

# Connector plugin connect-timeplus-proton-sink-connector

##########

RUN 'mkdir' '-p'
'/opt/kafka/plugins/connect-timeplus-proton-sink-connector/a7b3eb29' \
      && 'curl' '-f' '-L' '--output' '/opt/kafka/plugins/connect-timeplus-proton-sink-connector/a7b3eb29/a7b3eb29.jar' 'https://*****/generic/connect_timeplus/1.0.5/kafka-timeplus-connector-sink-1.0.5.jar'

``

This still gives me error same error as above . Any idea?

@neodino I did not get any error from the log you attached, do you mean you still get the same error like you previously mentioned?

neodino commented 6 months ago

sorry, see partial error below. Seems similar syntax error like before

Apr 14, 2024 11:05:27 PM com.timeplus.kafkaconnect.TimeplusSinkTask put
SEVERE: ingest to Timeplus failed : message -> Bad Request
Apr 14, 2024 11:05:27 PM com.timeplus.kafkaconnect.TimeplusSinkTask put
SEVERE: ingest to Timeplus failed : response -> Code: 62. DB::Exception: Syntax error: failed at position 1 ('{'): {"data":[["{method=publish, payload={data={symbol=NVDL, ask_size=1.0, tape=C, ask_exchange=Q, bid_size=1.0, bid_exchange=P, conditions=[R], bid_price=38.85, tim. Expected one of: Query, Query with output, EXPLAIN, SELECT query, possibly with UNION, list of union elements, SELECT query, subquery, possibly with UNION, SELECT subquery, SELECT query, WITH, SELECT, SUBSCRIBE TO SELECT query, possibly with UNION, SUBSCRIBE, UNSUBSCRIBE FROM SELECT query, possibly with UNION SETTINGS query_id=uuid, UNSUBSCRIBE, RECOVER FROM SELECT query, possibly with UNION SETTINGS query_id=uuid, RECOVER, SHOW CREATE QUOTA query, SHOW CREATE, SHOW CREATE FORMAT SCHEMA query, SHOW, SHOW [TEMPORARY] TABLES|DATABASES|CLUSTERS|CLUSTER 'name' [[NOT] [I]LIKE 'str'] [LIMIT expr], EXISTS or SHOW CREATE query, EXISTS, DESCRIBE FILESYSTEM CACHE query, DESCRIBE, DESC, DESCRIBE query, SHOW PROCESSLIST query, SHOW PROCESSLIST, CREATE STREAM or ATTACH STREAM query, CREATE, ATTACH, CREATE EXTERNAL TABLE query, CREATE DATABASE query, CREATE VIEW query, CREATE DICTIONARY, CREATE MATERIALIZED VIEW query, ALTER query, ALTER STREAM, ALTER DATABASE, RENAME query, RENAME STREAM, DROP query, DROP, DETACH, TRUNCATE, DROP EXTERNAL TABLE query, CHECK TABLE, KILL QUERY query, KILL, OPTIMIZE query, OPTIMIZE TABLE, WATCH query, WATCH, SHOW FORMAT SCHEMAS query, SHOW ACCESS query, SHOW ACCESS, ShowAccessEntitiesQuery, SHOW GRANTS query, SHOW GRANTS, SHOW PRIVILEGES query, SHOW PRIVILEGES, INSERT query, INSERT INTO, USE query, USE, SET ROLE or SET DEFAULT ROLE query, SET ROLE DEFAULT, SET ROLE, SET DEFAULT ROLE, SET query, SET, SYSTEM query, SYSTEM, CREATE USER or ALTER USER query, ALTER USER, CREATE USER, CREATE ROLE or ALTER ROLE query, ALTER ROLE, CREATE ROLE, CREATE QUOTA or ALTER QUOTA query, ALTER QUOTA, CREATE QUOTA, CREATE ROW POLICY or ALTER ROW POLICY query, CREATE SETTINGS PROFILE or ALTER SETTINGS PROFILE query, CREATE FUNCTION query, CREATE FORMAT SCHEMA query, DROP FORMAT SCHEMA query, DROP FUNCTION query, DROP access entity query, GRANT or REVOKE query, REVOKE, GRANT, EXTERNAL DDL query, EXTERNAL DDL FROM, TCL query, BEGIN TRANSACTION, COMMIT, ROLLBACK, SET TRANSACTION SNAPSHOT, BACKUP or RESTORE query, BACKUP, RESTORE. (SYNTAX_ERROR) (version 1.5.6)
Apr 14, 2024 11:05:27 PM com.timeplus.kafkaconnect.TimeplusSinkTask put
SEVERE: ingest to Timeplus failed : payload -> {"data":[["{method=publish, payload={data={symbol=NVDL, ask_size=1.0, tape=C, ask_exchange=Q, bid_size=1.0, bid_exchange=P, conditions=[R], bid_price=38.85, timestamp=2024-04-12T21:31:17.931420Z, ask_price=38.95}, channel=quotes_NVDL}}"],["{method=publish, payload={data={symbol=NVDL, ask_size=1.0, tape=C, ask_exchange=Z, bid_size=1.0, bid_exchange=P, conditions=[R], bid_price=38.85, timestamp=2024-04-12T21:31:17.931469Z, ask_price=39.0}, channel=quotes_NVDL}}"],["{method=publish, payload={data={symbol=NVDL, ask_size=1.0, tape=C, ask_exchange=Q, bid_size=1.0, bid_exchange=P, conditions=[R], bid_price=38.85, timestamp=2024-04-12T21:31:17.935597Z, ask_price=38.97}, channel=quotes_NVDL}}"],["{method=publish, payload={data={symbol=NVDL, ask_size=2.0, tape=C, ask_exchange=Q, bid_size=1.0, bid_exchange=P, conditions=[R], bid_price=38.85, timestamp=2024-04-12T21:31:17.935621Z, ask_price=38.97}, channel=quotes_NVDL}}"],["{method=publish, payload={data={symbol=NVDL, ask_size=2.0, tape=C, ask_exchange=Q, bid_size=1.0, bid_exchange=P, conditions=[R], bid_price=38.73, timestamp=2024-04-12T21:31:17.935684Z, ask_price=38.97}, channel=quotes_NVDL}}"],["{method=publish, payload={data={symbol=NVDL, ask_size=1.0, tape=C, ask_exchange=Q, bid_size=1.0, bid_exchange=P, conditions=[R], bid_price=38.73, timestamp=2024-04-12T21:31:17.935860Z, ask_price=38.97}, channel=quotes_NVDL}}"],["{method=publish, payload={data={symbol=NVDL, ask_size=1.0, tape=C, ask_exchange=Z, bid_size=1.0, bid_exchange=P, con
gangtao commented 6 months ago

sorry, see partial error below. Seems similar syntax error like before

Apr 14, 2024 11:05:27 PM com.timeplus.kafkaconnect.TimeplusSinkTask put
SEVERE: ingest to Timeplus failed : message -> Bad Request
Apr 14, 2024 11:05:27 PM com.timeplus.kafkaconnect.TimeplusSinkTask put
SEVERE: ingest to Timeplus failed : response -> Code: 62. DB::Exception: Syntax error: failed at position 1 ('{'): {"data":[["{method=publish, payload={data={symbol=NVDL, ask_size=1.0, tape=C, ask_exchange=Q, bid_size=1.0, bid_exchange=P, conditions=[R], bid_price=38.85, tim. Expected one of: Query, Query with output, EXPLAIN, SELECT query, possibly with UNION, list of union elements, SELECT query, subquery, possibly with UNION, SELECT subquery, SELECT query, WITH, SELECT, SUBSCRIBE TO SELECT query, possibly with UNION, SUBSCRIBE, UNSUBSCRIBE FROM SELECT query, possibly with UNION SETTINGS query_id=uuid, UNSUBSCRIBE, RECOVER FROM SELECT query, possibly with UNION SETTINGS query_id=uuid, RECOVER, SHOW CREATE QUOTA query, SHOW CREATE, SHOW CREATE FORMAT SCHEMA query, SHOW, SHOW [TEMPORARY] TABLES|DATABASES|CLUSTERS|CLUSTER 'name' [[NOT] [I]LIKE 'str'] [LIMIT expr], EXISTS or SHOW CREATE query, EXISTS, DESCRIBE FILESYSTEM CACHE query, DESCRIBE, DESC, DESCRIBE query, SHOW PROCESSLIST query, SHOW PROCESSLIST, CREATE STREAM or ATTACH STREAM query, CREATE, ATTACH, CREATE EXTERNAL TABLE query, CREATE DATABASE query, CREATE VIEW query, CREATE DICTIONARY, CREATE MATERIALIZED VIEW query, ALTER query, ALTER STREAM, ALTER DATABASE, RENAME query, RENAME STREAM, DROP query, DROP, DETACH, TRUNCATE, DROP EXTERNAL TABLE query, CHECK TABLE, KILL QUERY query, KILL, OPTIMIZE query, OPTIMIZE TABLE, WATCH query, WATCH, SHOW FORMAT SCHEMAS query, SHOW ACCESS query, SHOW ACCESS, ShowAccessEntitiesQuery, SHOW GRANTS query, SHOW GRANTS, SHOW PRIVILEGES query, SHOW PRIVILEGES, INSERT query, INSERT INTO, USE query, USE, SET ROLE or SET DEFAULT ROLE query, SET ROLE DEFAULT, SET ROLE, SET DEFAULT ROLE, SET query, SET, SYSTEM query, SYSTEM, CREATE USER or ALTER USER query, ALTER USER, CREATE USER, CREATE ROLE or ALTER ROLE query, ALTER ROLE, CREATE ROLE, CREATE QUOTA or ALTER QUOTA query, ALTER QUOTA, CREATE QUOTA, CREATE ROW POLICY or ALTER ROW POLICY query, CREATE SETTINGS PROFILE or ALTER SETTINGS PROFILE query, CREATE FUNCTION query, CREATE FORMAT SCHEMA query, DROP FORMAT SCHEMA query, DROP FUNCTION query, DROP access entity query, GRANT or REVOKE query, REVOKE, GRANT, EXTERNAL DDL query, EXTERNAL DDL FROM, TCL query, BEGIN TRANSACTION, COMMIT, ROLLBACK, SET TRANSACTION SNAPSHOT, BACKUP or RESTORE query, BACKUP, RESTORE. (SYNTAX_ERROR) (version 1.5.6)
Apr 14, 2024 11:05:27 PM com.timeplus.kafkaconnect.TimeplusSinkTask put
SEVERE: ingest to Timeplus failed : payload -> {"data":[["{method=publish, payload={data={symbol=NVDL, ask_size=1.0, tape=C, ask_exchange=Q, bid_size=1.0, bid_exchange=P, conditions=[R], bid_price=38.85, timestamp=2024-04-12T21:31:17.931420Z, ask_price=38.95}, channel=quotes_NVDL}}"],["{method=publish, payload={data={symbol=NVDL, ask_size=1.0, tape=C, ask_exchange=Z, bid_size=1.0, bid_exchange=P, conditions=[R], bid_price=38.85, timestamp=2024-04-12T21:31:17.931469Z, ask_price=39.0}, channel=quotes_NVDL}}"],["{method=publish, payload={data={symbol=NVDL, ask_size=1.0, tape=C, ask_exchange=Q, bid_size=1.0, bid_exchange=P, conditions=[R], bid_price=38.85, timestamp=2024-04-12T21:31:17.935597Z, ask_price=38.97}, channel=quotes_NVDL}}"],["{method=publish, payload={data={symbol=NVDL, ask_size=2.0, tape=C, ask_exchange=Q, bid_size=1.0, bid_exchange=P, conditions=[R], bid_price=38.85, timestamp=2024-04-12T21:31:17.935621Z, ask_price=38.97}, channel=quotes_NVDL}}"],["{method=publish, payload={data={symbol=NVDL, ask_size=2.0, tape=C, ask_exchange=Q, bid_size=1.0, bid_exchange=P, conditions=[R], bid_price=38.73, timestamp=2024-04-12T21:31:17.935684Z, ask_price=38.97}, channel=quotes_NVDL}}"],["{method=publish, payload={data={symbol=NVDL, ask_size=1.0, tape=C, ask_exchange=Q, bid_size=1.0, bid_exchange=P, conditions=[R], bid_price=38.73, timestamp=2024-04-12T21:31:17.935860Z, ask_price=38.97}, channel=quotes_NVDL}}"],["{method=publish, payload={data={symbol=NVDL, ask_size=1.0, tape=C, ask_exchange=Z, bid_size=1.0, bid_exchange=P, con

Hi @neodino , can you also share following information:

  1. your connector configuration, especically timeplus.sink.dataFormat timeplus.sink.stream
  2. your proton stream schema, if a target stream has been created.

according to your log, seems the payload is incompelete, it could a logging issue which I am not sure. feel free to join our slack https://timeplus.com/slack and ping me where we can do talk about your issue.