# Latest **URL:** https://forum.confluent.io/latest.md?page=1 [Latest](https://forum.confluent.io/latest.md) · [Categories](https://forum.confluent.io/categories.md) **Page:** 2 --- ## [How to stop RowFileInputReader after matching a specific line pattern (Text Header + Large Binary Tail)](https://forum.confluent.io/t/how-to-stop-rowfileinputreader-after-matching-a-specific-line-pattern-text-header-large-binary-tail/38260)
**Author:** [@I-am-a-monster](https://forum.confluent.io/u/I-am-a-monster)\ **Replies:** 1\ **Last updated:** [24 February 2026 14:43 UTC](https://forum.confluent.io/t/how-to-stop-rowfileinputreader-after-matching-a-specific-line-pattern-text-header-large-binary-tail/38260 "2026-02-24T14:43:35Z")
Hi everyone, I am using kafka-connect-file-pulse to process files that have a specific hybrid structure: A multi-line text header An empty line or custom characters line as a line separator A large amount of binary da… --- ## [S3 Sink Connector use file hash as Object name](https://forum.confluent.io/t/s3-sink-connector-use-file-hash-as-object-name/38259)
**Author:** [@truezjz](https://forum.confluent.io/u/truezjz)\ **Replies:** 3\ **Last updated:** [23 February 2026 17:56 UTC](https://forum.confluent.io/t/s3-sink-connector-use-file-hash-as-object-name/38259 "2026-02-23T17:56:31Z")
Hi, I am trying to use S3 Sink Connector to upload files reading from FilePulse connector. I want to the file hash (SHA256) as the the file name in S3, the format I want is: key is the hash, //${key:0:2}/${key:2:4}/$… --- ## [BigQuery Sink Connector V2 fails on tombstone event with Avro and Upsert\_delete configs](https://forum.confluent.io/t/bigquery-sink-connector-v2-fails-on-tombstone-event-with-avro-and-upsert-delete-configs/38226)
**Author:** [@flaviuratiu](https://forum.confluent.io/u/flaviuratiu)\ **Replies:** 0\ **Last updated:** [19 January 2026 15:11 UTC](https://forum.confluent.io/t/bigquery-sink-connector-v2-fails-on-tombstone-event-with-avro-and-upsert-delete-configs/38226 "2026-01-19T15:11:46Z")
I’m facing an issue with a BigQuery Sink Connector V2 having Ingestion Mode UPSERT\_DELETE and AVRO keys and values. The following error is thrown when tombstone events are consumed: \`\`\` Error encountered in task lcc-g… --- ## [CompleteBatch Infinite Loop With BatchSize Greater Than 1](https://forum.confluent.io/t/completebatch-infinite-loop-with-batchsize-greater-than-1/37640)
**Author:** [@khamburg](https://forum.confluent.io/u/khamburg)\ **Replies:** 6\ **Last updated:** [2 February 2026 21:13 UTC](https://forum.confluent.io/t/completebatch-infinite-loop-with-batchsize-greater-than-1/37640 "2026-02-02T21:13:39Z")
I have a Kafka Streams app and I’m implementing a production exception handler for messages that are too large for the destination topic. I noticed that if return FAIL from the handler and then restart my app, it will go… --- ## [Does a tombstone in toTable() propagate to downstream groupBy/aggregate if the key never existed?](https://forum.confluent.io/t/does-a-tombstone-in-totable-propagate-to-downstream-groupby-aggregate-if-the-key-never-existed/38239)
**Author:** [@Dawid](https://forum.confluent.io/u/Dawid)\ **Replies:** 3\ **Last updated:** [2 February 2026 20:19 UTC](https://forum.confluent.io/t/does-a-tombstone-in-totable-propagate-to-downstream-groupby-aggregate-if-the-key-never-existed/38239 "2026-02-02T20:19:07Z")
Hi, I have a questions about the behavior of tombstones in Kafka Streams topology when using toTable() followed by groupBy() and aggregate(). Simplified code looks like this: \ .process(MyPro… --- ## [Debezium SQL Server v2: Best practices for handling Schema Namespace fragmentation across multiple DB shards (SpecificRecord issue)](https://forum.confluent.io/t/debezium-sql-server-v2-best-practices-for-handling-schema-namespace-fragmentation-across-multiple-db-shards-specificrecord-issue/38228)
**Author:** [@229178](https://forum.confluent.io/u/229178)\ **Replies:** 2\ **Last updated:** [29 January 2026 19:16 UTC](https://forum.confluent.io/t/debezium-sql-server-v2-best-practices-for-handling-schema-namespace-fragmentation-across-multiple-db-shards-specificrecord-issue/38228 "2026-01-29T19:16:07Z")
Hi everyone, I am looking for advice on how to handle Avro schema namespaces when ingesting data from multiple identical SQL Server databases (sharding scenario) using the FullyManaged SQL Server Connector v2. The Scen… --- ## [Idempotent Producer fails with fatal OutOfOrderSequenceException during initial metadata stabilization of multi-partition topics](https://forum.confluent.io/t/idempotent-producer-fails-with-fatal-outofordersequenceexception-during-initial-metadata-stabilization-of-multi-partition-topics/38227)
**Author:** [@CiprianAmza](https://forum.confluent.io/u/CiprianAmza)\ **Replies:** 1\ **Last updated:** [21 January 2026 22:46 UTC](https://forum.confluent.io/t/idempotent-producer-fails-with-fatal-outofordersequenceexception-during-initial-metadata-stabilization-of-multi-partition-topics/38227 "2026-01-21T22:46:50Z")
Hello, When creating a new topic with a high number of partitions (e.g., 64) and a replication factor of 3, there is a race condition between the AdminClient confirming topic creation and all partition leaders becoming … --- ## [Didn't receive certification or badge after CCDAK Exam](https://forum.confluent.io/t/didnt-receive-certification-or-badge-after-ccdak-exam/38224)
**Author:** [@adugar](https://forum.confluent.io/u/adugar)\ **Replies:** 1\ **Last updated:** [16 January 2026 16:10 UTC](https://forum.confluent.io/t/didnt-receive-certification-or-badge-after-ccdak-exam/38224 "2026-01-16T16:10:56Z")
Hi team, I completed my CCDAK exam recently, but I haven’t received the certification or badge yet. I used the same email ID for both the exam and my Confluent account, so I’m not sure what might be causing the delay. C… --- ## [Issue consuming Avro](https://forum.confluent.io/t/issue-consuming-avro/38223)
**Author:** [@ernesto.costa](https://forum.confluent.io/u/ernesto.costa)\ **Replies:** 1\ **Last updated:** [14 January 2026 09:46 UTC](https://forum.confluent.io/t/issue-consuming-avro/38223 "2026-01-14T09:46:44Z")
Hi, I’m facing an issue when running a simple query trying to consume a normal topic with Avro data. The query is select \* from sdm.dk.sales.sales-orders.v1 Below you can see the show create table result. CREATE TABL… --- ## [Error while getting broker list. (io.confluent.admin.utils.ClusterStatus) java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment. Call: listNodes](https://forum.confluent.io/t/error-while-getting-broker-list-io-confluent-admin-utils-clusterstatus-java-util-concurrent-executionexception-org-apache-kafka-common-errors-timeoutexception-timed-out-waiting-for-a-node-assignment-call-listnodes/38221)
**Author:** [@KafkaGuy45](https://forum.confluent.io/u/KafkaGuy45)\ **Replies:** 1\ **Last updated:** [8 January 2026 14:29 UTC](https://forum.confluent.io/t/error-while-getting-broker-list-io-confluent-admin-utils-clusterstatus-java-util-concurrent-executionexception-org-apache-kafka-common-errors-timeoutexception-timed-out-waiting-for-a-node-assignment-call-listnodes/38221 "2026-01-08T14:29:14Z")
Hi, I recently started working with Kafka, but I’m having trouble getting the schema registry to start in this project. GitHub - p4535992/kafka-learning TESTED WITH 7.6.1 and 7.9.5 I get this error in the logs : docke… --- ## [Cluster - pre-upgrade - which version to use?](https://forum.confluent.io/t/cluster-pre-upgrade-which-version-to-use/38214)
**Author:** [@ebjy](https://forum.confluent.io/u/ebjy)\ **Replies:** 1\ **Last updated:** [8 January 2026 09:34 UTC](https://forum.confluent.io/t/cluster-pre-upgrade-which-version-to-use/38214 "2026-01-08T09:34:26Z")
It appears that Im using ‘confluent-kafka-2.11-2.0.1cp8-1.noarch’. Before I move to whatever is next should I switch to using the ‘confluent-community’ package(s)? This package seems to appear when the repo file is upda… --- ## [Migrating v old installation (v5.x) to latest](https://forum.confluent.io/t/migrating-v-old-installation-v5-x-to-latest/38199)
**Author:** [@ebjy](https://forum.confluent.io/u/ebjy)\ **Replies:** 9\ **Last updated:** [5 January 2026 17:38 UTC](https://forum.confluent.io/t/migrating-v-old-installation-v5-x-to-latest/38199 "2026-01-05T17:38:27Z")
I have 5 brokers running rocky 9 and ‘confluent-kafka-2.11-2.0.1cp8-1’. The yum repo is ‘https://packages.confluent.io/rpm/5.0’ - which Im guessing is 3 major versions behind. The goal is to land on the latest (v8.x) wi… --- ## [CVE‑2025‑12183 this vulnerability compression.type for topic and producer](https://forum.confluent.io/t/cve-2025-12183-this-vulnerability-compression-type-for-topic-and-producer/38200)
**Author:** [@asif123](https://forum.confluent.io/u/asif123)\ **Replies:** 1\ **Last updated:** [5 January 2026 15:49 UTC](https://forum.confluent.io/t/cve-2025-12183-this-vulnerability-compression-type-for-topic-and-producer/38200 "2026-01-05T15:49:08Z")
Please assist to check the compression.type configuration for Kafka Broker and also at topic level to assess if CVE‐2025‐12183 is affecting applications. This is with regards to the latest vulnerability found related to… --- ## [Migrating v new installation (v.2.x) to old](https://forum.confluent.io/t/migrating-v-new-installation-v-2-x-to-old/38205)
**Author:** [@infntypro62](https://forum.confluent.io/u/infntypro62)\ **Replies:** 0\ **Last updated:** [26 December 2025 12:57 UTC](https://forum.confluent.io/t/migrating-v-new-installation-v-2-x-to-old/38205 "2025-12-26T12:57:20Z")
I tried to find instructions about the upgrade, but it looks like 5 → 6 is old. The opposite documents do not show any information about the upgrade path. What is the truth behind that? --- ## [Kafka heterogeneous struct file connector](https://forum.confluent.io/t/kafka-heterogeneous-struct-file-connector/38198)
**Author:** [@I-am-a-monster](https://forum.confluent.io/u/I-am-a-monster)\ **Replies:** 1\ **Last updated:** [11 December 2025 16:07 UTC](https://forum.confluent.io/t/kafka-heterogeneous-struct-file-connector/38198 "2025-12-11T16:07:30Z")
Hey everyone, I am new to this community and would like to request your help. I’m exploring how to ingest files into Kafka in a distributed environment, and I’m trying to figure out the most reliable way to do it using… --- ## [Reading windowed topic into a global store](https://forum.confluent.io/t/reading-windowed-topic-into-a-global-store/38194)
**Author:** [@ahpo6Moh](https://forum.confluent.io/u/ahpo6Moh)\ **Replies:** 5\ **Last updated:** [10 December 2025 13:01 UTC](https://forum.confluent.io/t/reading-windowed-topic-into-a-global-store/38194 "2025-12-10T13:01:12Z")
I’ve got a consumer whose topology is defined using the Processor API. I want to read a new topic into a global store, to query that store from an existing processor. The topic is produced by another Kafka Streams applic… --- ## [Question on kafka ssl certificate refresh](https://forum.confluent.io/t/question-on-kafka-ssl-certificate-refresh/38197)
**Author:** [@theo123490](https://forum.confluent.io/u/theo123490)\ **Replies:** 0\ **Last updated:** [9 December 2025 10:47 UTC](https://forum.confluent.io/t/question-on-kafka-ssl-certificate-refresh/38197 "2025-12-09T10:47:58Z")
We have a kafka version 3 cluster using KRaft with SSL as the listener and contoller. We want to do a cert rotate on this certificate without doing a kafka restart. We have been able to update the certificate on the list… --- ## [Kafka Metadata Quorum Check Fails During Controller Setup – Connection Refused to Broker](https://forum.confluent.io/t/kafka-metadata-quorum-check-fails-during-controller-setup-connection-refused-to-broker/38195)
**Author:** [@Shaheerahmad](https://forum.confluent.io/u/Shaheerahmad)\ **Replies:** 0\ **Last updated:** [4 December 2025 08:46 UTC](https://forum.confluent.io/t/kafka-metadata-quorum-check-fails-during-controller-setup-connection-refused-to-broker/38195 "2025-12-04T08:46:18Z")
Hi Confluent Community, I’m running into an issue while setting up a new KRaft-based Kafka cluster using Ansible and the confluent.platform.kafka\_controller role. The deployment is failing at the \*\*“Check Kafka Metadata… --- ## [Data pipeline troubleshooting - Root cause analysis with lineage metadata](https://forum.confluent.io/t/data-pipeline-troubleshooting-root-cause-analysis-with-lineage-metadata/38192)
**Author:** [@alice.richardson](https://forum.confluent.io/u/alice.richardson)\ **Replies:** 0\ **Last updated:** [1 December 2025 10:09 UTC](https://forum.confluent.io/t/data-pipeline-troubleshooting-root-cause-analysis-with-lineage-metadata/38192 "2025-12-01T10:09:31Z")
Watch the recording and ask questions about this event in this thread! :spiral\_calendar: When: 27 November 2025 at 18:00 CEST :speaking\_head: Speaker(s): Mario Fiore Vitale, Open-Source Contributor and Debezium Contri… --- ## [The Kafka connector JDBC produces events validating schema value and schema ID](https://forum.confluent.io/t/the-kafka-connector-jdbc-produces-events-validating-schema-value-and-schema-id/38185)
**Author:** [@kjovano](https://forum.confluent.io/u/kjovano)\ **Replies:** 0\ **Last updated:** [25 November 2025 22:34 UTC](https://forum.confluent.io/t/the-kafka-connector-jdbc-produces-events-validating-schema-value-and-schema-id/38185 "2025-11-25T22:34:30Z")
Kafka JDBC connector producing events validating schema value and schema ID. So, I have a topic with JSON Schema Value and JSON Schema Key. My connector needs to produce events that validate the schemas, i.e., magic typ… --- ## [Feasibility of Using Confluent Cloud Schema Registry with GCP Managed Kafka](https://forum.confluent.io/t/feasibility-of-using-confluent-cloud-schema-registry-with-gcp-managed-kafka/38182)
**Author:** [@Archita](https://forum.confluent.io/u/Archita)\ **Replies:** 7\ **Last updated:** [25 November 2025 10:48 UTC](https://forum.confluent.io/t/feasibility-of-using-confluent-cloud-schema-registry-with-gcp-managed-kafka/38182 "2025-11-25T10:48:25Z")
Hi Team, I’m exploring the possibility of integrating Confluent Cloud Schema Registry with an external Kafka cluster, specifically GCP Managed Kafka (Google Cloud Managed Kafka / Apache Kafka service). I went through t… --- ## [Ahmed from France](https://forum.confluent.io/t/ahmed-from-france/38183)
**Author:** [@ahmedtoumi](https://forum.confluent.io/u/ahmedtoumi)\ **Replies:** 0\ **Last updated:** [23 November 2025 22:20 UTC](https://forum.confluent.io/t/ahmed-from-france/38183 "2025-11-23T22:20:57Z")
Hi everyone, I was here since a while and I never introduced myself. So I’m Ahmed from France working as Kafka Dev & Ops, and I’m joining here to try to learn more and keep myself up to date . --- ## [Kafka connect sink prometheus, influxdb](https://forum.confluent.io/t/kafka-connect-sink-prometheus-influxdb/38181)
**Author:** [@kcj3054](https://forum.confluent.io/u/kcj3054)\ **Replies:** 0\ **Last updated:** [18 November 2025 06:53 UTC](https://forum.confluent.io/t/kafka-connect-sink-prometheus-influxdb/38181 "2025-11-18T06:53:38Z")
Hi, I’m currently trying to build a pipeline where time-series data flows like this: file -\> Fluent Bit -\> Kafka -\> Kafka Connect (Prometheus sink or InfluxDB sink) -\> Grafana Which sink (Prometheus vs InfluxDB) would… --- ## [Kafka KRaft Cluster SASL Inter-Broker Authentication Failure: Unexpected Request During Handshake](https://forum.confluent.io/t/kafka-kraft-cluster-sasl-inter-broker-authentication-failure-unexpected-request-during-handshake/38180)
**Author:** [@risky-bit](https://forum.confluent.io/u/risky-bit)\ **Replies:** 0\ **Last updated:** [13 November 2025 10:28 UTC](https://forum.confluent.io/t/kafka-kraft-cluster-sasl-inter-broker-authentication-failure-unexpected-request-during-handshake/38180 "2025-11-13T10:28:20Z")
I am setting up a 3-node Apache Kafka cluster using KRaft mode (3.9.0) with SCRAM-SHA-256 for inter-broker communication on the SASL\_PLAINTEXT listener. The cluster is unable to form a quorum due to persistent SASL authe… --- ## [Using ConsumerTimestampsInterceptor with kafka Streams](https://forum.confluent.io/t/using-consumertimestampsinterceptor-with-kafka-streams/38177)
**Author:** [@onlymohan](https://forum.confluent.io/u/onlymohan)\ **Replies:** 1\ **Last updated:** [12 November 2025 19:32 UTC](https://forum.confluent.io/t/using-consumertimestampsinterceptor-with-kafka-streams/38177 "2025-11-12T19:32:24Z")
Hi, Does using ConsumerTimestampsInterceptor work with Kafka streams? We have 2 clusters replicating data across regions with confluent replicator. If the streams is consuming from east, we want to make sure the offset… --- ## [Confluent Cloud organization ID in Google Cloud](https://forum.confluent.io/t/confluent-cloud-organization-id-in-google-cloud/38176)
**Author:** [@alfredojury](https://forum.confluent.io/u/alfredojury)\ **Replies:** 2\ **Last updated:** [7 November 2025 16:02 UTC](https://forum.confluent.io/t/confluent-cloud-organization-id-in-google-cloud/38176 "2025-11-07T16:02:58Z")
Hi All, I’m setting up a vpc peering to connect our GCP project to our cluster in Confluent Cloud. As per the below Confluent documentation, I have to find out the Confluent Cloud org ID in Google Cloud in order to whit… --- ## [LibRdKafka C++ (1.9.1 and 2.10.1) KafkaConsumer::consume method returns ERR\_\_TIMED\_OUT when there are more messages in the brokers](https://forum.confluent.io/t/librdkafka-c-1-9-1-and-2-10-1-kafkaconsumer-consume-method-returns-err-timed-out-when-there-are-more-messages-in-the-brokers/38099)
**Author:** [@Cameron](https://forum.confluent.io/u/Cameron)\ **Replies:** 7\ **Last updated:** [7 November 2025 03:58 UTC](https://forum.confluent.io/t/librdkafka-c-1-9-1-and-2-10-1-kafkaconsumer-consume-method-returns-err-timed-out-when-there-are-more-messages-in-the-brokers/38099 "2025-11-07T03:58:44Z")
My Test: Produce (RdKafka::Producer::produce(..)) 200 messages with payload 1Kb In a loop (until 200 messages consumed): KafkaConsumer::consume (timeout = 100 ms) I hit the timeout 10 times while retrieving messages … --- ## [Confluent 8.0 – KRaft Combined Mode Production Availability](https://forum.confluent.io/t/confluent-8-0-kraft-combined-mode-production-availability/38171)
**Author:** [@manjunathkmph](https://forum.confluent.io/u/manjunathkmph)\ **Replies:** 2\ **Last updated:** [5 November 2025 14:50 UTC](https://forum.confluent.io/t/confluent-8-0-kraft-combined-mode-production-availability/38171 "2025-11-05T14:50:21Z")
I am upgrading Confluent from version 7.9.X to 8.0 by deprecating the ZooKeeper cluster and enabling KRaft mode in production. To reduce costs, we have decided not to add any additional nodes to the Kafka cluster to act … --- ## [Export topics, ACLs and other configuration as JSON/text](https://forum.confluent.io/t/export-topics-acls-and-other-configuration-as-json-text/38165)
**Author:** [@maek48](https://forum.confluent.io/u/maek48)\ **Replies:** 5\ **Last updated:** [4 November 2025 09:52 UTC](https://forum.confluent.io/t/export-topics-acls-and-other-configuration-as-json-text/38165 "2025-11-04T09:52:37Z")
I’m surprised I’m unable to find more posts like this, frankly. We have a cluster, it’s running fine, but we want to move from making configuration changes from a git repository (YAML files and Ansible playbooks) to mak… --- ## [JMX exporter configuration for Kraft combined mode](https://forum.confluent.io/t/jmx-exporter-configuration-for-kraft-combined-mode/38164)
**Author:** [@miles](https://forum.confluent.io/u/miles)\ **Replies:** 1\ **Last updated:** [31 October 2025 19:12 UTC](https://forum.confluent.io/t/jmx-exporter-configuration-for-kraft-combined-mode/38164 "2025-10-31T19:12:39Z")
Hello, I am running cp-kafka on a node in the kraft combined mode(broker+controller), and I would like to monitor this kafka instance with JMX exporter+prometheus. I am aware of the jmx exporter configuration file in t… [Previous page](https://forum.confluent.io/latest.md) [Next page](https://forum.confluent.io/latest.md?page=2)