# Latest **URL:** https://forum.confluent.io/latest.md [Latest](https://forum.confluent.io/latest.md) · [Categories](https://forum.confluent.io/categories.md) --- ## [How are people monitoring consumer lag without going full Datadog?](https://forum.confluent.io/t/how-are-people-monitoring-consumer-lag-without-going-full-datadog/38515)
**Author:** [@q.tryharder](https://forum.confluent.io/u/q.tryharder)\ **Replies:** 1\ **Last updated:** [17 September 2026 17:24 UTC](https://forum.confluent.io/t/how-are-people-monitoring-consumer-lag-without-going-full-datadog/38515 "2026-09-17T17:24:41Z")
Trying to get a read on this before building anything — for teams on Confluent Cloud, what do you use to catch a consumer group falling behind or a DLQ growing? Is it a DIY Grafana/Prometheus/Burrow setup, one of the big… --- ## [Issue after upgrading to CMF 2.4.2/CFK 3.3.0: FlinkApplication resolution fails cross-namespace FlinkEnvironment](https://forum.confluent.io/t/issue-after-upgrading-to-cmf-2-4-2-cfk-3-3-0-flinkapplication-resolution-fails-cross-namespace-flinkenvironment/38516)
**Author:** [@TinyToons](https://forum.confluent.io/u/TinyToons)\ **Replies:** 0\ **Last updated:** [17 September 2026 13:49 UTC](https://forum.confluent.io/t/issue-after-upgrading-to-cmf-2-4-2-cfk-3-3-0-flinkapplication-resolution-fails-cross-namespace-flinkenvironment/38516 "2026-09-17T13:49:57Z")
Hi everyone, After upgrading Confluent Manager for Flink (CMF) from 2.3.2 to 2.4.2 and Confluent For Kubernetes (CFK) from 3.2.1 to 3.3.0, CFK fails to reconcile an existing FlinkApplication. It seems to look for the F… --- ## [What does each Confluent Cloud invoice line\_type actually bill for? Sanity-checking my mapping](https://forum.confluent.io/t/what-does-each-confluent-cloud-invoice-line-type-actually-bill-for-sanity-checking-my-mapping/38509)
**Author:** [@mithrandirr](https://forum.confluent.io/u/mithrandirr)\ **Replies:** 2\ **Last updated:** [7 September 2026 18:27 UTC](https://forum.confluent.io/t/what-does-each-confluent-cloud-invoice-line-type-actually-bill-for-sanity-checking-my-mapping/38509 "2026-09-07T18:27:22Z")
I’ve been reconciling Confluent Cloud invoices line by line, mapping every line\_type in the billing CSV to what it actually meters. I’d like to check my understanding before relying on it. line\_type I think it bills … --- ## [Getting license expired issue with connect worker - cp 8.3 CE](https://forum.confluent.io/t/getting-license-expired-issue-with-connect-worker-cp-8-3-ce/38507)
**Author:** [@gouravk](https://forum.confluent.io/u/gouravk)\ **Replies:** 1\ **Last updated:** [25 August 2026 19:04 UTC](https://forum.confluent.io/t/getting-license-expired-issue-with-connect-worker-cp-8-3-ce/38507 "2026-08-25T19:04:58Z")
License Clarification for Confluent Platform 8.3 Community Edition and JDBC Connector. I was previously using Apache Kafka 2.0 with 3 node cluster and am currently working on migrating to Confluent Platform 8.3 Communit… --- ## [MQ Summit 2026 - announcing the speaker lineup](https://forum.confluent.io/t/mq-summit-2026-announcing-the-speaker-lineup/38479)
**Author:** [@paulinaprochorowska](https://forum.confluent.io/u/paulinaprochorowska)\ **Replies:** 0\ **Last updated:** [11 August 2026 11:42 UTC](https://forum.confluent.io/t/mq-summit-2026-announcing-the-speaker-lineup/38479 "2026-08-11T11:42:53Z")
MQ Summit is a conference built around messaging and event-driven systems. It grew out of RabbitMQ Summit and now brings the whole ecosystem into one room: RabbitMQ, Kafka, NATS, Pulsar, ActiveMQ, IBM MQ, Amazon SQS/MQ, … --- ## [Hello from Rinki — Enterprise Architecture, Kafka/Flink and AI Readiness](https://forum.confluent.io/t/hello-from-rinki-enterprise-architecture-kafka-flink-and-ai-readiness/38478)
**Author:** [@Rinki](https://forum.confluent.io/u/Rinki)\ **Replies:** 0\ **Last updated:** [5 August 2026 22:25 UTC](https://forum.confluent.io/t/hello-from-rinki-enterprise-architecture-kafka-flink-and-ai-readiness/38478 "2026-08-05T22:25:53Z")
Hello everyone, I’m Rinki Basu, an Enterprise, Cloud and AI Architect based in the New York/New Jersey area. My work focuses on enterprise modernization, event-driven architecture, Kafka and Flink-based platforms, hybr… --- ## [Need a little help regarding Kafka integration in a Power Platform architecture scenario](https://forum.confluent.io/t/need-a-little-help-regarding-kafka-integration-in-a-power-platform-architecture-scenario/38475)
**Author:** [@edula](https://forum.confluent.io/u/edula)\ **Replies:** 1\ **Last updated:** [5 August 2026 22:14 UTC](https://forum.confluent.io/t/need-a-little-help-regarding-kafka-integration-in-a-power-platform-architecture-scenario/38475 "2026-08-05T22:14:12Z")
Hello everyone, I’m now studying for my GH-300 Certification and came across a practice question involving the integration between Kafka and the Power Platform solution. While I know how the publish-and-subscribe mechan… --- ## [Kafma — a desktop Kafka UI tool for faster debugging](https://forum.confluent.io/t/kafma-a-desktop-kafka-ui-tool-for-faster-debugging/38471)
**Author:** [@karma](https://forum.confluent.io/u/karma)\ **Replies:** 0\ **Last updated:** [4 August 2026 02:35 UTC](https://forum.confluent.io/t/kafma-a-desktop-kafka-ui-tool-for-faster-debugging/38471 "2026-08-04T02:35:23Z")
Hi everyone, We’re excited to share Kafma v1.0.0 — a desktop Kafka GUI client and IDE designed to keep the consume–inspect–produce loop in one workspace and quickly clone remote topics to your local cluster for testing. … --- ## [CFK 3.3.0 - FlinkEnvironment is never reconciled, operator logs cmfDay2OpsEnabled=false](https://forum.confluent.io/t/cfk-3-3-0-flinkenvironment-is-never-reconciled-operator-logs-cmfday2opsenabled-false/38470)
**Author:** [@LHP02052003](https://forum.confluent.io/u/LHP02052003)\ **Replies:** 0\ **Last updated:** [31 July 2026 10:21 UTC](https://forum.confluent.io/t/cfk-3-3-0-flinkenvironment-is-never-reconciled-operator-logs-cmfday2opsenabled-false/38470 "2026-07-31T10:21:12Z")
Hi everyone, I’m evaluating Confluent Manager for Apache Flink (CMF) together with Confluent for Kubernetes (CFK) on OpenShift. I’m encountering an issue where a FlinkEnvironment resource is created successfully but is… --- ## [Low volume compact topic not deleting old messages](https://forum.confluent.io/t/low-volume-compact-topic-not-deleting-old-messages/38438)
**Author:** [@ernesto.costa](https://forum.confluent.io/u/ernesto.costa)\ **Replies:** 1\ **Last updated:** [22 June 2026 21:23 UTC](https://forum.confluent.io/t/low-volume-compact-topic-not-deleting-old-messages/38438 "2026-06-22T21:23:36Z")
Hi, We’re having some difficulties when it comes to topics with low volume of messages being sent to them and compaction. Example: the topic has the following settings: cleanup.policy compact delete.retention… --- ## [Mirrormaker2 getting disconnect errors from source kafka](https://forum.confluent.io/t/mirrormaker2-getting-disconnect-errors-from-source-kafka/38430)
**Author:** [@itsrg2512](https://forum.confluent.io/u/itsrg2512)\ **Replies:** 8\ **Last updated:** [18 June 2026 17:59 UTC](https://forum.confluent.io/t/mirrormaker2-getting-disconnect-errors-from-source-kafka/38430 "2026-06-18T17:59:54Z")
Hi I am trying to sync kafka data from source to a target kafka cluster using the kafka-connect hosted on target kafka cluster as bootstrap server and then using mirrormaker connectors on it, with below configuration. T… --- ## [Breaking change in default strategy?](https://forum.confluent.io/t/breaking-change-in-default-strategy/38437)
**Author:** [@joebowbeer](https://forum.confluent.io/u/joebowbeer)\ **Replies:** 0\ **Last updated:** [18 June 2026 17:55 UTC](https://forum.confluent.io/t/breaking-change-in-default-strategy/38437 "2026-06-18T17:55:27Z")
Where can I find out more about the process that led to the change in default strategy from TopicNameStrategy to AssociatedNameStrategy? I found this commit, but I can’t find more than that. I can’t even find a callout … --- ## [ksqlDB JSON\_SR with existing KEY\_SCHEMA\_ID fails on structured key: Incompatible schema of type JSON / id.compatibility.strict](https://forum.confluent.io/t/ksqldb-json-sr-with-existing-key-schema-id-fails-on-structured-key-incompatible-schema-of-type-json-id-compatibility-strict/38374)
**Author:** [@Ethan2029](https://forum.confluent.io/u/Ethan2029)\ **Replies:** 0\ **Last updated:** [17 May 2026 11:45 UTC](https://forum.confluent.io/t/ksqldb-json-sr-with-existing-key-schema-id-fails-on-structured-key-incompatible-schema-of-type-json-id-compatibility-strict/38374 "2026-05-17T11:45:44Z")
Hi Confluent community, I am looking for advice on a ksqlDB / JSON\_SR / Schema Registry issue. Context We have the following flow: Source topic: raw JSON, no Schema Registry ksqlDB: transforms the payload into the ta… --- ## [TimeBasedPartitioner always writes records to year=1970 when timestamp.field is epoch seconds (like this 1740487898), even after Cast + TimestampConverter SMT conversion](https://forum.confluent.io/t/timebasedpartitioner-always-writes-records-to-year-1970-when-timestamp-field-is-epoch-seconds-like-this-1740487898-even-after-cast-timestampconverter-smt-conversion/38337)
**Author:** [@helin](https://forum.confluent.io/u/helin)\ **Replies:** 1\ **Last updated:** [4 May 2026 18:34 UTC](https://forum.confluent.io/t/timebasedpartitioner-always-writes-records-to-year-1970-when-timestamp-field-is-epoch-seconds-like-this-1740487898-even-after-cast-timestampconverter-smt-conversion/38337 "2026-05-04T18:34:04Z")
In Confluent GCS Sink (11.0.9), records contain date as epoch seconds (e.g., 1773516258), but with timestamp.extractor=RecordField and timestamp.field=date, partition paths still resolve to 1970; we tested SMT chains (Ca… --- ## [Freelance role - Kafka developer](https://forum.confluent.io/t/freelance-role-kafka-developer/38359)
**Author:** [@jodyhesch](https://forum.confluent.io/u/jodyhesch)\ **Replies:** 0\ **Last updated:** [30 April 2026 21:19 UTC](https://forum.confluent.io/t/freelance-role-kafka-developer/38359 "2026-04-30T21:19:10Z")
I’ve got the following contract role for any interested freelancers: Role: Streaming, Governance & Integration Engineer Start: End of May Commitment: 40 hrs / week Duration: 6+ months Working Timezone: CST Rate: $9… --- ## [SQL Server sink connector error](https://forum.confluent.io/t/sql-server-sink-connector-error/38196)
**Author:** [@chris9751689](https://forum.confluent.io/u/chris9751689)\ **Replies:** 5\ **Last updated:** [23 April 2026 08:59 UTC](https://forum.confluent.io/t/sql-server-sink-connector-error/38196 "2026-04-23T08:59:42Z")
Hope someone can help! I have the below error for kafka connect sink to sql server local db, the jar file is successfully loading when the connector starts in docker. I can see a slight difference where the mssql jar doe… --- ## [Kafka Streams EOS - Producer fenced](https://forum.confluent.io/t/kafka-streams-eos-producer-fenced/38325)
**Author:** [@roookeee](https://forum.confluent.io/u/roookeee)\ **Replies:** 4\ **Last updated:** [16 April 2026 09:08 UTC](https://forum.confluent.io/t/kafka-streams-eos-producer-fenced/38325 "2026-04-16T09:08:49Z")
I am currently trying to get rid of the following error in our EOS-configured Kafka Streams Spring Boot application: org.apache.kafka.common.errors.InvalidProducerEpochException: Producer attempted to produce with an o… --- ## [Jetty version mismatch](https://forum.confluent.io/t/jetty-version-mismatch/38291)
**Author:** [@Smrutiranjan209](https://forum.confluent.io/u/Smrutiranjan209)\ **Replies:** 2\ **Last updated:** [9 April 2026 11:13 UTC](https://forum.confluent.io/t/jetty-version-mismatch/38291 "2026-04-09T11:13:22Z")
Hi Team, We are currently using kafka-schema-registry-client version 8.1.1, which depends on Jetty 9.4.58.v20250814. We would like to know if there are any plans to upgrade Jetty to the 12.0.x series in upcoming releas… --- ## [Recording ready to view: SPEAKER Q&A THREAD: 25 March 2026 - Apache Kafka® for Python Developers - A code intensive journey](https://forum.confluent.io/t/recording-ready-to-view-speaker-q-a-thread-25-march-2026-apache-kafka-for-python-developers-a-code-intensive-journey/38333)
**Author:** [@alice.richardson](https://forum.confluent.io/u/alice.richardson)\ **Replies:** 0\ **Last updated:** [9 April 2026 08:27 UTC](https://forum.confluent.io/t/recording-ready-to-view-speaker-q-a-thread-25-march-2026-apache-kafka-for-python-developers-a-code-intensive-journey/38333 "2026-04-09T08:27:03Z")
Watch the recording and ask questions about this event in this thread! :spiral\_calendar: When: 25 March 2026 at 11:00 (UTC) :speaking\_head: Speaker(s): Diptiman Raichaudhuri :notebook\_with\_decorative\_cover: Talk(s): A… --- ## [Billing issue – No response on support ticket #347335](https://forum.confluent.io/t/billing-issue-no-response-on-support-ticket-347335/38330)
**Author:** [@tanu-ns](https://forum.confluent.io/u/tanu-ns)\ **Replies:** 1\ **Last updated:** [7 April 2026 16:33 UTC](https://forum.confluent.io/t/billing-issue-no-response-on-support-ticket-347335/38330 "2026-04-07T16:33:27Z")
Hi, I opened a billing support request (#347335) regarding a $369.33 charge on my Confluent Cloud account, but I have not yet received a response. This usage was accidental during a workshop, and I have already deleted… --- ## [Kafka Streams FK-join: force result timestamp to always come from main (left) flow](https://forum.confluent.io/t/kafka-streams-fk-join-force-result-timestamp-to-always-come-from-main-left-flow/38286)
**Author:** [@foal](https://forum.confluent.io/u/foal)\ **Replies:** 5\ **Last updated:** [20 March 2026 17:23 UTC](https://forum.confluent.io/t/kafka-streams-fk-join-force-result-timestamp-to-always-come-from-main-left-flow/38286 "2026-03-20T17:23:56Z")
Hi, we use Kafka Streams 4.1.1 and need guidance on FK-join timestamp behaviour. Concrete example (generalised): Main flow record (authoritative entity): timestamp T\_main=1000 Enrichment flow record (auxiliary update)… --- ## [KTable-KTable Foreign-Key LEFT JOIN: Discrepancy between documentation and behavior when FK is NULL](https://forum.confluent.io/t/ktable-ktable-foreign-key-left-join-discrepancy-between-documentation-and-behavior-when-fk-is-null/38300)
**Author:** [@foal](https://forum.confluent.io/u/foal)\ **Replies:** 1\ **Last updated:** [20 March 2026 17:22 UTC](https://forum.confluent.io/t/ktable-ktable-foreign-key-left-join-discrepancy-between-documentation-and-behavior-when-fk-is-null/38300 "2026-03-20T17:22:19Z")
KTable-KTable Foreign-Key LEFT JOIN: Discrepancy between documentation and behavior when FK is NULL Summary I’m observing a discrepancy between the documented semantics table and the actual runtime behavior of KTable-KTa… --- ## [Unable to migrate metadata from zookeeper to KRaft](https://forum.confluent.io/t/unable-to-migrate-metadata-from-zookeeper-to-kraft/38287)
**Author:** [@Agaikwad](https://forum.confluent.io/u/Agaikwad)\ **Replies:** 0\ **Last updated:** [13 March 2026 13:07 UTC](https://forum.confluent.io/t/unable-to-migrate-metadata-from-zookeeper-to-kraft/38287 "2026-03-13T13:07:51Z")
Using Confluent kafka 7.9.4-1. Following the documentation of migration from zookeeper to KRaft i completed setting up my controller and its able to communicate with my broker . but the migration is not getting complet… --- ## [CFK deployment of Schema R prefix setting appears to be ignored](https://forum.confluent.io/t/cfk-deployment-of-schema-r-prefix-setting-appears-to-be-ignored/38276)
**Author:** [@simonjd](https://forum.confluent.io/u/simonjd)\ **Replies:** 8\ **Last updated:** [12 March 2026 10:12 UTC](https://forum.confluent.io/t/cfk-deployment-of-schema-r-prefix-setting-appears-to-be-ignored/38276 "2026-03-12T10:12:17Z")
Hi I am observing an issue when attempting to deploy version 8.0.0 of Schema registry on an OpenShift system where Confluent is deployed via the CFK operator What seems to be happening is if you define a value in the s… --- ## [Kafka Streams and Schemaregistry interaction, multiple teams, languages](https://forum.confluent.io/t/kafka-streams-and-schemaregistry-interaction-multiple-teams-languages/38277)
**Author:** [@lukas\_dev](https://forum.confluent.io/u/lukas_dev)\ **Replies:** 2\ **Last updated:** [6 March 2026 13:16 UTC](https://forum.confluent.io/t/kafka-streams-and-schemaregistry-interaction-multiple-teams-languages/38277 "2026-03-06T13:16:45Z")
Hello! We use Confluent and Schemaregistry, with protos. There is an upstream team working in Dotnet, which makes schema evolution progress. I work in the downstream BI team, working in Java. We consume from their top… --- ## [Kafka Streams - bizarre data loss](https://forum.confluent.io/t/kafka-streams-bizarre-data-loss/38261)
**Author:** [@roookeee](https://forum.confluent.io/u/roookeee)\ **Replies:** 8\ **Last updated:** [5 March 2026 21:13 UTC](https://forum.confluent.io/t/kafka-streams-bizarre-data-loss/38261 "2026-03-05T21:13:52Z")
We are currently investigating a data loss in our Kafka Streams application. Both the state store and outbound topic message got lost for a single message (which we detected by pure chance, and yes, only one message got… --- ## [SR with CfK; Enable ACL =\> ConfigException: Listener unsupported scheme 'EXTERNAL'](https://forum.confluent.io/t/sr-with-cfk-enable-acl-configexception-listener-unsupported-scheme-external/38245)
**Author:** [@s1c4](https://forum.confluent.io/u/s1c4)\ **Replies:** 2\ **Last updated:** [3 March 2026 15:15 UTC](https://forum.confluent.io/t/sr-with-cfk-enable-acl-configexception-listener-unsupported-scheme-external/38245 "2026-03-03T15:15:31Z")
Hello, I have this setup: Self-managed platform v8.1.1 configured via CfK v3.1.1 SchemaRegistry is configured to use HTTPS on external listener and plain HTTP on internal one, using the Kubernetes Schema Rregistry CR I… --- ## [Max Partitions missing from Cluster display](https://forum.confluent.io/t/max-partitions-missing-from-cluster-display/38268)
**Author:** [@richship](https://forum.confluent.io/u/richship)\ **Replies:** 4\ **Last updated:** [2 March 2026 17:09 UTC](https://forum.confluent.io/t/max-partitions-missing-from-cluster-display/38268 "2026-03-02T17:09:49Z")
Looks like there has been a change in the Cluster Overview page. It used to show “xxxx partitions used of yyyy available” or similar, but now only shows the partitions used. Is there still a way to show the maximum part… --- ## [Elasticsearch 9 support timeline and contribution question](https://forum.confluent.io/t/elasticsearch-9-support-timeline-and-contribution-question/38269)
**Author:** [@yk1113](https://forum.confluent.io/u/yk1113)\ **Replies:** 0\ **Last updated:** [26 February 2026 20:35 UTC](https://forum.confluent.io/t/elasticsearch-9-support-timeline-and-contribution-question/38269 "2026-02-26T20:35:57Z")
Hi everyone, First, thank you to the maintainers for the continued work on this connector. It is truly appreciated. I am referring to the issue about adding support for Elasticsearch 9.0.0: Is there any visibility i… --- ## [Topic message headers getting encoded during sync using mirrormaker](https://forum.confluent.io/t/topic-message-headers-getting-encoded-during-sync-using-mirrormaker/38267)
**Author:** [@itsrg2512](https://forum.confluent.io/u/itsrg2512)\ **Replies:** 5\ **Last updated:** [26 February 2026 16:36 UTC](https://forum.confluent.io/t/topic-message-headers-getting-encoded-during-sync-using-mirrormaker/38267 "2026-02-26T16:36:43Z")
I am trying to sync kafka data from source to a target kafka cluster using the kafka-connect hosted on target kafka cluster as bootstrap server and then using mirrormaker connectors on it, with below configuration. The t… [Next page](https://forum.confluent.io/latest.md?page=1)