# Latest **URL:** https://ask.lenses.io/latest.md [Latest](https://ask.lenses.io/latest.md) · [Categories](https://ask.lenses.io/categories.md) · [Tags](https://ask.lenses.io/tags.md) --- ## [S3 connector restart to backup data](https://ask.lenses.io/t/s3-connector-restart-to-backup-data/205)
**Author:** [@cwoodruff](https://ask.lenses.io/u/cwoodruff)\ **Replies:** 4\ **Last updated:** [August 24, 2026, 8:57am UTC](https://ask.lenses.io/t/s3-connector-restart-to-backup-data/205 "2026-08-24T08:57:03Z")
Is there a way to restart a running s3 sink connector so it captures any changes made to the topic and saves it to s3? If not, is a new connector required to capture the data changes in the topic? --- ## [Issue with Broker Decommissioning in Lenses After Node Pool Change](https://ask.lenses.io/t/issue-with-broker-decommissioning-in-lenses-after-node-pool-change/499)
**Author:** [@iMajna](https://ask.lenses.io/u/iMajna)\ **Replies:** 0\ **Last updated:** [August 24, 2026, 8:56am UTC](https://ask.lenses.io/t/issue-with-broker-decommissioning-in-lenses-after-node-pool-change/499 "2026-08-24T08:56:45Z")
Hi, We are running a Strimzi cluster using KRaft and Node Pools. After switching our storage backend, we created a new node pool and removed the old one. Lenses correctly identified the new brokers, but it still display… --- ## [ADLS Gen2 Sink + Snowpipe: FlushWithClose never generated ](https://ask.lenses.io/t/adls-gen2-sink-snowpipe-flushwithclose-never-generated/497)
**Author:** [@albertoG](https://ask.lenses.io/u/albertoG)\ **Replies:** 0\ **Last updated:** [August 24, 2026, 8:56am UTC](https://ask.lenses.io/t/adls-gen2-sink-snowpipe-flushwithclose-never-generated/497 "2026-08-24T08:56:19Z")
Hi everyone, I'm using the DatalakeSinkConnector (StreamReactor v11) to write Parquet files to Azure Data Lake Storage Gen2, and I'm trying to set up Snowpipe (Snowflake automated ingest) to load them automatically. Th… --- ## [Does Lenses support Kraft metrics over Jolokia](https://ask.lenses.io/t/does-lenses-support-kraft-metrics-over-jolokia/487)
**Author:** [@PeterHallerborn](https://ask.lenses.io/u/PeterHallerborn)\ **Replies:** 3\ **Last updated:** [August 18, 2026, 10:11am UTC](https://ask.lenses.io/t/does-lenses-support-kraft-metrics-over-jolokia/487 "2026-08-18T10:11:42Z")
Hello. We are currently upgrading to the latest Confluent Platform version and want to use Lenses for the Migration. Of course this means we will go with Kraft instead of the legacy Kafka consensus mechanism. We will in… --- ## [How to view the Kubernetes namespaces in Lenses K2K?](https://ask.lenses.io/t/how-to-view-the-kubernetes-namespaces-in-lenses-k2k/488)
**Author:** [@PeterHallerborn](https://ask.lenses.io/u/PeterHallerborn)\ **Replies:** 2\ **Last updated:** [August 18, 2026, 10:08am UTC](https://ask.lenses.io/t/how-to-view-the-kubernetes-namespaces-in-lenses-k2k/488 "2026-08-18T10:08:27Z")
Hello. I have a second question. We want to migrate from our old platform to the latest Confluent Platform version using Lenses K2K. When I want to configure the K2K app I have to select a Kubernetes namespace but none … --- ## [SQL Processor - "SQL Invalid" error when using FORMAT\_DATE(\_meta.timestamp)](https://ask.lenses.io/t/sql-processor-sql-invalid-error-when-using-format-date-meta-timestamp/362)
**Author:** [@wkolbenschlag](https://ask.lenses.io/u/wkolbenschlag)\ **Replies:** 8\ **Last updated:** [July 6, 2026, 7:48pm UTC](https://ask.lenses.io/t/sql-processor-sql-invalid-error-when-using-format-date-meta-timestamp/362 "2026-07-06T19:48:21Z")
Getting errors while attempting to create an SQL Processor in Lenses: SQL Processor statement: INSERT INTO my\_topic STORE VALUE AS AVRO SELECT STREAM field\_a as \_key, field\_b, FORMAT\_DATE(\_meta.timestamp,… --- ## [Error creating SQL Processor (but works with admin user)](https://ask.lenses.io/t/error-creating-sql-processor-but-works-with-admin-user/376)
**Author:** [@Patrick\_Polster](https://ask.lenses.io/u/Patrick_Polster)\ **Replies:** 1\ **Last updated:** [July 1, 2026, 9:42am UTC](https://ask.lenses.io/t/error-creating-sql-processor-but-works-with-admin-user/376 "2026-07-01T09:42:56Z")
Error creating SQL Processor. Works with admin user. Gives weird Error message. Error Message: The sql execution mode is not set. please contact your administrator --- ## [Lenses setup using MS SQL server](https://ask.lenses.io/t/lenses-setup-using-ms-sql-server/482)
**Author:** [@manindra](https://ask.lenses.io/u/manindra)\ **Replies:** 1\ **Last updated:** [May 26, 2026, 1:34pm UTC](https://ask.lenses.io/t/lenses-setup-using-ms-sql-server/482 "2026-05-26T13:34:47Z")
Hi Team, I am setup lenses HQ and lenses agent of lenses-ce using docker . I could see Lenses HQ required Postgres . Does Lenses HQ support other Database also like SQL server DB instead of Postgres . Planning to setup… --- ## [Option to update KEY value in the messages pulled using MQTT Source Connector for Kafka](https://ask.lenses.io/t/option-to-update-key-value-in-the-messages-pulled-using-mqtt-source-connector-for-kafka/480)
**Author:** [@noeltoms](https://ask.lenses.io/u/noeltoms)\ **Replies:** 1\ **Last updated:** [May 12, 2026, 9:09am UTC](https://ask.lenses.io/t/option-to-update-key-value-in-the-messages-pulled-using-mqtt-source-connector-for-kafka/480 "2026-05-12T09:09:39Z")
I am using MQTT Source Connector to pull MQTT messages from an external broker to my AWS MSK Kafka. My Kafka topic has 6 partitions, but all the messages are going to one single partition. On checking the messages receiv… --- ## [How to set up MQTT Connector in an MSK environment](https://ask.lenses.io/t/how-to-set-up-mqtt-connector-in-an-msk-environment/369)
**Author:** [@Benjamin\_Baek](https://ask.lenses.io/u/Benjamin_Baek)\ **Replies:** 1\ **Last updated:** [May 11, 2026, 5:11pm UTC](https://ask.lenses.io/t/how-to-set-up-mqtt-connector-in-an-msk-environment/369 "2026-05-11T17:11:49Z")
Hello. When setting up the MQTT connector in my MSK environment, for some reason my setup is consistently failing to deploy. I must be missing something, but I don’t know what it is. I need the ability to: configure… --- ## [Lenses is sending many requests against our MSK JMX endpoint](https://ask.lenses.io/t/lenses-is-sending-many-requests-against-our-msk-jmx-endpoint/470)
**Author:** [@kacaha8004](https://ask.lenses.io/u/kacaha8004)\ **Replies:** 2\ **Last updated:** [May 4, 2026, 8:51am UTC](https://ask.lenses.io/t/lenses-is-sending-many-requests-against-our-msk-jmx-endpoint/470 "2026-05-04T08:51:36Z")
Hi Marios, do you know why Lenses sends so many JMX requests against MSK? We’re seeing a high volume of JMX traffic from Lenses to the MSK cluster and want to understand whether this is expected behavior, configurable … --- ## [Is there a way our JSON Schemas are automatically updated?](https://ask.lenses.io/t/is-there-a-way-our-json-schemas-are-automatically-updated/471)
**Author:** [@kacaha8004](https://ask.lenses.io/u/kacaha8004)\ **Replies:** 2\ **Last updated:** [May 4, 2026, 8:51am UTC](https://ask.lenses.io/t/is-there-a-way-our-json-schemas-are-automatically-updated/471 "2026-05-04T08:51:00Z")
Hi again Marios. is it possible in Lenses to get or infer the latest JSON schema from a topic? At the moment, it looks like Lenses only analyzes the first message in the topic, but our producers have evolved since then… --- ## [Where can I configure Kafka Connect?](https://ask.lenses.io/t/where-can-i-configure-kafka-connect/472)
**Author:** [@kacaha8004](https://ask.lenses.io/u/kacaha8004)\ **Replies:** 2\ **Last updated:** [May 4, 2026, 8:50am UTC](https://ask.lenses.io/t/where-can-i-configure-kafka-connect/472 "2026-05-04T08:50:21Z")
I’m trying to check how Kafka Connect is configured and managed from Lenses, but I’m not sure where this is exposed in the Lenses HQ SQL Studio interface. --- ## [Lenses GCP Sink connector writing to temp but but not to actual location](https://ask.lenses.io/t/lenses-gcp-sink-connector-writing-to-temp-but-but-not-to-actual-location/469)
**Author:** [@superbrain\_bug](https://ask.lenses.io/u/superbrain_bug)\ **Replies:** 1\ **Last updated:** [April 21, 2026, 8:19am UTC](https://ask.lenses.io/t/lenses-gcp-sink-connector-writing-to-temp-but-but-not-to-actual-location/469 "2026-04-21T08:19:31Z")
Hi Everyone, We are experiencing the issue with GCP Sink connector where connector is writing data to tmp folder and data is missing from actual location. We use following libs: StreamReactor GCP Sink connector 11.1 … --- ## [How to reference file in HQ config file in EC2 instance](https://ask.lenses.io/t/how-to-reference-file-in-hq-config-file-in-ec2-instance/468)
**Author:** [@superbrain\_bug](https://ask.lenses.io/u/superbrain_bug)\ **Replies:** 1\ **Last updated:** [April 1, 2026, 2:02pm UTC](https://ask.lenses.io/t/how-to-reference-file-in-hq-config-file-in-ec2-instance/468 "2026-04-01T14:02:02Z")
Hello Lenses Support Team, We would like to raise a request regarding the current setup for Lenses login and SAML/SSO integration. At present, the SAML/SSO metadata file needs to be embedded directly within the configu… --- ## [Impossible to login with default username and password through traefik ingress on a local Kubernetes lab environment](https://ask.lenses.io/t/impossible-to-login-with-default-username-and-password-through-traefik-ingress-on-a-local-kubernetes-lab-environment/467)
**Author:** [@Ismael\_Kizito\_Papa](https://ask.lenses.io/u/Ismael_Kizito_Papa)\ **Replies:** 1\ **Last updated:** [March 18, 2026, 11:04am UTC](https://ask.lenses.io/t/impossible-to-login-with-default-username-and-password-through-traefik-ingress-on-a-local-kubernetes-lab-environment/467 "2026-03-18T11:04:11Z")
I have installed Lenses HQ on my local KubeADM on a Macbook Pro. I have used port-forwarding to access the login page and login works fine for it. Now I want to avoid having to use port-forwarding I have apply the trae… --- ## [Lenses Agent v6 not updating to new Schema Registry URL](https://ask.lenses.io/t/lenses-agent-v6-not-updating-to-new-schema-registry-url/466)
**Author:** [@superbrain\_bug](https://ask.lenses.io/u/superbrain_bug)\ **Replies:** 1\ **Last updated:** [February 25, 2026, 12:14pm UTC](https://ask.lenses.io/t/lenses-agent-v6-not-updating-to-new-schema-registry-url/466 "2026-02-25T12:14:43Z")
I’ve checked the provision.yaml file and the schema url is correctly updated there $ kubectl exec -n lenses lenses-agent-000111b7f8-btbhh – ls -la /mnt/provision-secrets/files/ confluentSchemaRegistry: configuration: … --- ## [llm integration for Kafka](https://ask.lenses.io/t/llm-integration-for-kafka/462)
**Author:** [@Teddy\_Kuk](https://ask.lenses.io/u/Teddy_Kuk)\ **Replies:** 2\ **Last updated:** [February 18, 2026, 3:09pm UTC](https://ask.lenses.io/t/llm-integration-for-kafka/462 "2026-02-18T15:09:47Z")
I want to build some AI Agents connect to my Kafka cluster to analyse some streams. What approach have people taken? The Flink community are marketing this quite a lot, is this a valid solution? --- ## [Difference between Lenses & Conduktor](https://ask.lenses.io/t/difference-between-lenses-conduktor/455)
**Author:** [@james1985](https://ask.lenses.io/u/james1985)\ **Replies:** 1\ **Last updated:** [January 27, 2026, 6:34pm UTC](https://ask.lenses.io/t/difference-between-lenses-conduktor/455 "2026-01-27T18:34:55Z")
I’ve been using Lenses Community Edition for some time and our Kafka adoption has grown. We’re now looking to deploy an enterprise solution. Conduktor.io would be the alternative option but seems a bit different. What… --- ## [Issue: Incomplete and duplicated topic restore from S3 to AWS MSK using Lenses S3 Source Connector](https://ask.lenses.io/t/issue-incomplete-and-duplicated-topic-restore-from-s3-to-aws-msk-using-lenses-s3-source-connector/459)
**Author:** [@Barnabas\_Lukacs](https://ask.lenses.io/u/Barnabas_Lukacs)\ **Replies:** 2\ **Last updated:** [January 23, 2026, 10:33pm UTC](https://ask.lenses.io/t/issue-incomplete-and-duplicated-topic-restore-from-s3-to-aws-msk-using-lenses-s3-source-connector/459 "2026-01-23T22:33:51Z")
I am backing up all topics from an AWS MSK cluster to Amazon S3 using the Lenses Kafka Connect AWS S3 connector (kafka-connect-aws-s3-8.1.33.zip). Backup configuration I use the following S3 Sink Connector configuratio… --- ## [Gcs Storage Sink Connector Production issue (gcs data loss)](https://ask.lenses.io/t/gcs-storage-sink-connector-production-issue-gcs-data-loss/453)
**Author:** [@Umar\_Cheema](https://ask.lenses.io/u/Umar_Cheema)\ **Replies:** 6\ **Last updated:** [December 19, 2025, 3:32pm UTC](https://ask.lenses.io/t/gcs-storage-sink-connector-production-issue-gcs-data-loss/453 "2025-12-19T15:32:40Z")
Hi everyone, I previously raised this issue( GCPStorage sink plugin committed offsets ) regarding GCS bucket versioning and offset commits. When versioning is enabled and a file (Avro or Parquet) is uploaded, the offset… --- ## [Unable to serialize record error with SQL Processors](https://ask.lenses.io/t/unable-to-serialize-record-error-with-sql-processors/444)
**Author:** [@james1985](https://ask.lenses.io/u/james1985)\ **Replies:** 1\ **Last updated:** [November 26, 2025, 3:02pm UTC](https://ask.lenses.io/t/unable-to-serialize-record-error-with-sql-processors/444 "2025-11-26T15:02:33Z")
I’m trying to create a SQL Processor that converts an XML topic (VBAK\_VBAP\_2) to a new topic. SET defaults.topic.autocreate=true; INSERT INTO VBAK\_VBAP\_JSON STORE KEY AS STRING VALUE AS STRING SELECT STREAM \* FROM VBAK… --- ## [Database Migration issues](https://ask.lenses.io/t/database-migration-issues/452)
**Author:** [@nikhitha\_chandana](https://ask.lenses.io/u/nikhitha_chandana)\ **Replies:** 1\ **Last updated:** [November 26, 2025, 12:27pm UTC](https://ask.lenses.io/t/database-migration-issues/452 "2025-11-26T12:27:36Z")
Deployed latest lenses-hq and lenses-agent using community license. Seeing migration errors in agent. Can someone help me resolve this? Caused by: liquibase.exception.MigrationFailedException: Migration failed for chang… --- ## [Does Lenses Use Context 7?](https://ask.lenses.io/t/does-lenses-use-context-7/451)
**Author:** [@kafkaesque](https://ask.lenses.io/u/kafkaesque)\ **Replies:** 1\ **Last updated:** [November 10, 2025, 2:49pm UTC](https://ask.lenses.io/t/does-lenses-use-context-7/451 "2025-11-10T14:49:26Z")
Hello Does Lenses have Context7 setup for it’s MCP server? Thanks!!! --- ## [K2K standalone replication example on Community Edition with two localhost Kafka clusters](https://ask.lenses.io/t/k2k-standalone-replication-example-on-community-edition-with-two-localhost-kafka-clusters/448)
**Author:** [@james1985](https://ask.lenses.io/u/james1985)\ **Replies:** 1\ **Last updated:** [October 26, 2025, 8:18pm UTC](https://ask.lenses.io/t/k2k-standalone-replication-example-on-community-edition-with-two-localhost-kafka-clusters/448 "2025-10-26T20:18:08Z")
I want to test Lenses K2K replication between two clusters connected to Lenses Community edition. Does anyone have some good k2k pipeline examples I can copy from? --- ## [GCS Sink connector intermitten write issue](https://ask.lenses.io/t/gcs-sink-connector-intermitten-write-issue/447)
**Author:** [@superbrain\_bug](https://ask.lenses.io/u/superbrain_bug)\ **Replies:** 1\ **Last updated:** [October 22, 2025, 9:34am UTC](https://ask.lenses.io/t/gcs-sink-connector-intermitten-write-issue/447 "2025-10-22T09:34:58Z")
While running GCS Sink connector our connector stopped with following error message: {"name":"\*\*\*\*\*\*","connector":{"state":"RUNNING","worker\_id":"\*\*\*\*\*:8083"},"tasks":\[{"id":0,"state":"FAILED","worker\_id":"\*\*\*\*\*:8083","… --- ## [Example SQL Snapshot command to create Kafka topic with sales orders JSON events](https://ask.lenses.io/t/example-sql-snapshot-command-to-create-kafka-topic-with-sales-orders-json-events/446)
**Author:** [@james1985](https://ask.lenses.io/u/james1985)\ **Replies:** 1\ **Last updated:** [October 20, 2025, 11:42am UTC](https://ask.lenses.io/t/example-sql-snapshot-command-to-create-kafka-topic-with-sales-orders-json-events/446 "2025-10-20T11:42:01Z")
Here’s an SQL Snapshot example of creating Sales Order JSON topic and schema in Lenses: CREATE TABLE VBAK\_VBAP\_JSON ( \_key STRING , OrderID STRING , OrderDate STRING , Customer.CustomerID STRING … --- ## [Lenses MCP Server settings for Intellij AI](https://ask.lenses.io/t/lenses-mcp-server-settings-for-intellij-ai/442)
**Author:** [@james1985](https://ask.lenses.io/u/james1985)\ **Replies:** 1\ **Last updated:** [October 16, 2025, 10:17pm UTC](https://ask.lenses.io/t/lenses-mcp-server-settings-for-intellij-ai/442 "2025-10-16T22:17:40Z")
Anyone have an example mcpServers JSON config to setup Intellij AI to Lenses MCP Server? --- ## [Error in s3 sink connector The S3 storage state is corrupted](https://ask.lenses.io/t/error-in-s3-sink-connector-the-s3-storage-state-is-corrupted/438)
**Author:** [@Asaf\_Gur\_arie](https://ask.lenses.io/u/Asaf_Gur_arie)\ **Replies:** 2\ **Last updated:** [October 16, 2025, 8:45am UTC](https://ask.lenses.io/t/error-in-s3-sink-connector-the-s3-storage-state-is-corrupted/438 "2025-10-16T08:45:14Z")
hey from time to time we are getting this error The S3 storage state is corrupted. The connector state is out of sync the data. This could happen if the connector has been recreated and the data was deleted.\\nDelete the … --- ## [GCPStorage sink plugin committed offsets](https://ask.lenses.io/t/gcpstorage-sink-plugin-committed-offsets/437)
**Author:** [@Umar\_Cheema](https://ask.lenses.io/u/Umar_Cheema)\ **Replies:** 0\ **Last updated:** [October 2, 2025, 9:54am UTC](https://ask.lenses.io/t/gcpstorage-sink-plugin-committed-offsets/437 "2025-10-02T09:54:06Z")
We are using the GCP Storage Sink Connector with the following property set to false: “connect.gcpstorage.exactly.once.enable”: “false” In our test, we send 10 records, which are processed and written to a file. Howeve… [Next page](https://ask.lenses.io/latest.md?page=1)