5.0
SQL
Optimization settings for SQL queries.
Key | Description | Type | Default |
---|---|---|---|
lenses.sql.settings.max.size | Restricts the max bytes that a kafka sql query will return | long | 20971520 (20MB) |
lenses.sql.settings.max.query.time | Max time (in msec) that a sql query will run | int | 3600000 (1h) |
lenses.sql.settings.max.idle.time | Max time (in msec) for a query when it reaches the end of the topic | int | 5000 (5 sec) |
lenses.sql.settings.show.bad.records | By default show bad records when querying a kafka topic | boolean | true |
lenses.sql.settings.format.timestamp | By default convert AVRO date to human readable format | boolean | true |
lenses.sql.settings.live.aggs | By default allow aggregation queries on kafka data | boolean | true |
lenses.sql.sample.default | Number of messages to sample when live tailing a kafka topic | int | 2/window |
lenses.sql.sample.window | How frequently to sample messages when tailing a kafka topic | int | 200 msec |
lenses.sql.websocket.buffer | Buffer size for messages in a SQL query | int | 10000 |
lenses.metrics.workers | Number of workers for parallelising SQL queries | int | 16 |
lenses.kafka.ws.buffer.size | Buffer size for WebSocket consumer | int | 10000 |
lenses.kafka.ws.max.poll.records | Max number of kafka messages to return in a single poll() | long | 1000 |
lenses.sql.state.dir | Folder to store KStreams state. For CONNECT mode create the folders on kafka-connect workers | string | logs/lenses-sql-kstream-state |
lenses.sql.udf.packages | The list of allowed java packages for UDFs/UDAFs | array of strings | [“io.lenses.sql.udf”] |