KSQL 5.4.0 includes new features, including:
UDAFs support STRUCTs as parameters and return values.
KSQL now supports working with source data where the value is an anonymous Avro or JSON serialized
MAPor primitive type, for example
BIGINT. Previously KSQL required all Avro values to be Avro records, and all JSON values to be JSON objects. For more information, refer to Single field (un)wrapping.
KSQL now allows users to control how results containing only a single value field are serialized to Kafka. Users can now choose to serialize the single value as a named field within an outer Avro record or JSON object, depending on the format in use, or as an anonymous value. For more information, refer to Single field (un)wrapping.
A new config
ksql.metrics.tags.customfor adding custom tags to emitted JMX metrics. See ksql.metrics.tags.custom for usage.
KAFKAformat that supports
STRINGfields that have been serialized using the standard Kafka serializers, e.g.
The format only supports single values, i.e. only single field, being primarily intended for use as a key format.
User-defined table functions (UDTF) are now supported by KSQL, and
explode()has been added as a new built-in UDTF.
explode()takes an array as an argument, and outputs a row for each element in the array (essentially,
KSQL 5.4.0 includes the following misc. changes:
- Require either the value for a
@UdfParameteror for the UDF JAR to be compiled with the Java8
-parameterscompilation option. The UDF archetype now includes this flag.
KSQL 5.3.0 includes new features, including:
- Drop the requirement that
CREATE TABLEstatements must have a
KEYset in their
WITHclause. This is now an optional optimization to avoid unnecessary repartition steps. See Github issue #2745 for more info.
- Improved handling of
KEYfield is an optional copy of the Kafka record’s key held within the record’s value. Users can supply the name of the field that holds the copy of the key within the
WITHclause. The improved handling may eliminate unnecessary repartition steps in certain queries. Please note that preexisting persistent queries, e.g. those created via
CREATE TABLE AS SELECT ...or
CREATE STREAM AS SELECT ...or
INSERT INTO ..., will continue to have the unnecessary repartition step. This is required to avoid the potential for data loss should this step be dropped. See Github issue #2636 for more info.
INSERT INTO ... VALUESis now supported, with standard SQL syntax to insert rows to existing KSQL streams/tables. To disable this functionality, set
falsein the server properties.
CREATE TABLEwill now allow you to create the topic if it is missing. To do this, specify the
CREATE STREAM AS SELECT ...and
CREATE TABLE AS SELECT ...statements now use the source topic partitions and replica counts for the sink topic if the config properties are not set in the
WITHclause. In case of JOIN, the left hand side topic is used. This deprecates
- A new config variable,
ksql.internal.topic.replicas, was introduced to set the replica count for the internal topics created by KSQL Server. The internal topics include the command topic and the config topic.
- A new KSQL testing tool was added. The tool is a command line utility that enables testing KSQL statements without requiring any infrastructure, like Apache Kafka and KSQL clusters.
KSQL 5.3.0 includes bug fixes, including:
ROWTIMEof the row generated when a
JOINencounters late data was previous the
ROWTIMEof the late event, where as now it is the max of
ROWTIMEof the rows involved in the join. This provides more deterministic join semantics.
Return values of UDF and UDAFs are now correctly marked as optional, where previously there was potential for non-optional fields, which would result in serialization issues in the presence of
This is a forward compatible change in Avro, i.e. after upgrading, KSQL will be able to read old values using the new schema. However, it is important to ensure downstream consumers of the data are using the updated schema before upgrading KSQL, as otherwise deserialization may fail. The updated schema is best obtained from running the query in another KSQL cluster, running version 5.3.
See Github issue #2769 for more info.
Fixed issues with using
ASkeyword when aliasing sources. See #2732 for more info.
KSQL 5.2 includes new features, including:
- Support for HTTPS.
- Support for CASE expression: KSQL now supports CASE conditional expression in Searched form where KSQL evaluates each condition from left to right. It returns the result for the first condition that evaluates to true. If no condition evaluates to true, the result for the ELSE clause will be returned. If there is no ELSE clause, null is returned.
- A new family of UDFs for improved handling of URIs (e.g. extracting information/decoding information), see UDF table for all URL functions
LIMITkeyword support for
- Support for read-after-write consistency: new commands don’t execute until previous commands have finished executing. This feature is enabled by default in the CLI (#2280) and can be implemented by the user for the REST API (Coordinate Multiple Requests).
- A log of record processing events to help users debug their KSQL queries. The log can be configured to log to Kafka to be consumed as a KSQL stream. See KSQL processing log for more details.
- Aggregation functionality has been extended. KSQL now supports:
GROUP BYmore than just simple columns, including fields within structs, arithmetic results, functions, string concatenations and literals.
- literals in the projection, (a.k.a the
HAVINGclauses, including the use of aggregate functions and literals.
- Automatic compatibility management for queries in headless mode across versions. Starting with 5.2, KSQL will automatically take care of ensuring query compatibility when upgrading. This means you won’t need to worry about setting properties correctly during upgrade, as has been required for previous upgrades. Refer to the architecture documentation for details. Note that it is still up to the user to set properties correctly before upgrading to 5.2. The upgrade doc has details about the properties required to safely upgrade to 5.2.
KSQL 5.2 includes bug fixes, including:
- Improved support for multi-line requests in interactive mode deployments. Prior to version 5.2 KSQL parsed the full request before attempting to execute any statements. Requests that contained later statements that were dependent the execution of prior statements may have failed. In version 5.2 and later, this is no longer an issue.
- Improved support for non-interactive, “headless” mode deployments. Prior to version 5.2 KSQL parsed the full script before attempting to execute any statements. The full parse would often fail when later statements relied on the execution of earlier statements. In version 5.2 and later, this is no longer an issue.
KSQL 5.2 deprecates some features, including:
- The use of the
RUN SCRIPTstatement via the REST API is now deprecated and will be removed in the next major release. (Github issue 2179). The feature circumnavigates certain correctness checks and is unnecessary, given the script content can be supplied in the main body of the request. If you are using the
RUN SCRIPTfunctionality from the KSQL CLI you will not be affected, as this will continue to be supported. If you are using the
RUN SCRIPTfunctionality directly against the REST API your requests will work with the 5.2 server, but will be rejected after the next major version release. Instead, include the contents of the script in the main body of your request.
KSQL 5.1 includes new features, including:
- PR-2265 - MINOR: Fix bug encountered when restoring RUN SCRIPT
- PR-2240 - Bring version checker improvements to 5.1.x
- PR-2242 - KSQL-1795: First draft of STRUCT topic
- PR-2235 - KSQL-1794: First draft of query with arrays and maps topic
- PR-2239 - KSQL-1975: Fix munged Docker commands for kafkacat examples
- PR-2232 - KSQL-1912: Fix munged scalar functions table
- PR-2229 - KSQL-1912: Remove extraneous newline
- PR-2227 - KSQL-1912: Add IFNULL to Scalar Functions table
- PR-2219 - KSQL-1912: Add IFNULL function to functions table
- PR-2223 - KSQL-1958: Fix munged CSAS properties table YET AGAIN
- PR-2222 - KSQL-1957: Add links to new topics; also restore missing CSAS and CTAS text
- PR-2221 - DOCS-960: Add link to partitioning topic in key requirements section
- PR-2220 - DOCS-960: Add note about the KEY property
- PR-2134 - KSQL-1787: First draft of Time and Windows topic
- PR-2201 - KSQL-1930: Fix a typo in the new Transform a Stream topic
- PR-2180 - KSQL-1797: First draft of Transform a Stream topic
- PR-2181 - KSQL-1796: First draft of aggregation topic
- PR-2136 - Add reference about compatibility breaking configs in upgrade docs
- PR-2193 - Fix flaky json format test
- PR-2195 - 5.0.x fix flaky
- PR-2174 - DOCS-1006: Fix munged :: block
- PR-2170 - DOCS-911: Fix typos and grammatical errors
- PR-2169 - DOCS-911: Fix typos and grammatical errors
- PR-2142 - KSQL-1786: First draft of KSQL and KStreams topic
- PR-2165 - KSQL-1854: Merge partition sections
- PR-2143 - Fix some bugs in recovery logic
- PR-2156 - KSQL-1864: Remove ksql> prompt from example commands
- PR-2155 - KSQL-1864: Remove ksql> prompt from example commands
- PR-2152 - KSQL-1864: Remove $ chars prompts for example commands
- PR-2150 - Currently we don’t support AS for aliasing stream/table.
- PR-2149 - Using ksql topic name instead of Kafka topic name in topic map in metastore.
- PR-2137 - Clarify the description of SUBSTRING and its legacy mode setting.
- PR-2120 - KSQL-1789: First draft of Create a KSQL Table topic
- PR-2132 - KSQL-1853: Fix heading levels in join and partition topics
- PR-2130 - DOCS-950: Reworked partitions topic per feedback
- PR-2122 - Bringing back the commit that was lost because of bad merge.
- PR-2109 - KSQL-1799: New topic: Troubleshoot KSQL
- PR-2092 - Window’s UDF doc changes.
- PR-2090 - Add WindowStart and WindowEnd UDFs (#1993)
- PR-2075 - Disable optimizations for 5.1.x
- PR-2051 - Preserve originals when merging configs
- PR-2080 - Fixed the test.
- PR-2079 - Fix deprecation issues.
- PR-2031 - Fix deprecated issues in the build
- PR-2066 - Minor: Fix bug involving filters with NOT keyword.
- PR-2056 - Added stringtodate and datetostring UDFs for 5.1.x
- PR-2048 - Minor: Fix bug involving LIKE patterns without wildcards.
- PR-2045 - List UDAFs for 5.1.x
- PR-2043 - Bump airline version to 2.6.0
- PR-2023 - MINOR: Cause ‘ksql help’ and ‘ksql -help’ to behave the same as ‘ksql -h’ and ‘ksql –help’
- PR-1979 - Metrics refactor + fix a couple issues
- PR-2018 - Display stats timestamps in unambiguous format.
- PR-2017 - KSQL-1725: Fix tables and build warnings
- PR-1997 - MINOR: Remove duplicate junit dependency in ksql-examples
- PR-2014 - KSQL-1722: Fix broken inline literal
- PR-2007 - KSQL-1722: Fix build error in changelog.rst
- PR-1991 - Minor: Switch tests to use mock Kafka clients.
- PR-1992 - Minor: Improve test output for QueryTranslationTest
- PR-1999 - KSQL-1717: Fix build warning in faq.rst
- PR-1981 - ST-1153: Switch to use cp-base-new and bash-config to hide passwords by default
- PR-1977 - Use version 5.0.0 for KSQL server image
- PR-1955 - Hide ssl configs and refactor KsqlResourceTest