# Non-Java Clients **URL:** https://forum.confluent.io/c/clients/non-java-clients/25.md [Latest](https://forum.confluent.io/latest.md) · [Categories](https://forum.confluent.io/categories.md) --- ## [About the Non-Java Clients category](https://forum.confluent.io/t/about-the-non-java-clients-category/34)
**Author:** [@rmoff](https://forum.confluent.io/u/rmoff)\ **Replies:** 0\ **Last updated:** [5 November 2020 17:57 UTC](https://forum.confluent.io/t/about-the-non-java-clients-category/34 "2020-11-05T17:57:48Z")
(Replace this first paragraph with a brief description of your new category. This guidance will appear in the category selection area, so try to keep it below 200 characters.) Use the following paragraphs for a longer d… --- ## [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 … --- ## [Detail logging running on Console vs running in Azure Function](https://forum.confluent.io/t/detail-logging-running-on-console-vs-running-in-azure-function/37722)
**Author:** [@slamarre](https://forum.confluent.io/u/slamarre)\ **Replies:** 2\ **Last updated:** [1 May 2025 20:26 UTC](https://forum.confluent.io/t/detail-logging-running-on-console-vs-running-in-azure-function/37722 "2025-05-01T20:26:11Z")
I am using Confluent.Kafka NuGet v 2.1 package with Visual Studio 2022 with .NET 8. I have simple code to consume data from Kafka and when I run in a Console OR with an Azure Function locally on my machine, I can see al… --- ## [Compatibility of api (for .NET) confluent kafka ver. 2.0.2](https://forum.confluent.io/t/compatibility-of-api-for-net-confluent-kafka-ver-2-0-2/37666)
**Author:** [@fabrizio67](https://forum.confluent.io/u/fabrizio67)\ **Replies:** 1\ **Last updated:** [15 April 2025 13:18 UTC](https://forum.confluent.io/t/compatibility-of-api-for-net-confluent-kafka-ver-2-0-2/37666 "2025-04-15T13:18:31Z")
Since 2023, I have been using the Confluent Kafka API (for .NET) v. 2.0.2 in a client program I developed in C# . Here you are the web link of Confluent Kafka API (for .NET) v. 2.0.2 : Release 2.0.2 · confluentinc/confl… --- ## [Python / Avro Serialised payload onto Topic](https://forum.confluent.io/t/python-avro-serialised-payload-onto-topic/37548)
**Author:** [@georgelza](https://forum.confluent.io/u/georgelza)\ **Replies:** 2\ **Last updated:** [23 March 2025 16:40 UTC](https://forum.confluent.io/t/python-avro-serialised-payload-onto-topic/37548 "2025-03-23T16:40:47Z")
Hi all Bit stuck and not sure if I’m doing something wrong or simply misunderstanding… Previously wrote a Golang producer which serialised (with schema registry) a payload. I was able to still view the payload in Cont… --- ## [Determining if a producer is in an invalid state](https://forum.confluent.io/t/determining-if-a-producer-is-in-an-invalid-state/37511)
**Author:** [@ghughes](https://forum.confluent.io/u/ghughes)\ **Replies:** 0\ **Last updated:** [17 March 2025 21:08 UTC](https://forum.confluent.io/t/determining-if-a-producer-is-in-an-invalid-state/37511 "2025-03-17T21:08:04Z")
Hi, I’m using the .NET client and have seen some exceptions due to transactional producers being fenced. In this case, it seems that the fenced producer is no longer valid and should be disposed. I can catch these exc… --- ## [Kafka Producer Transactions threadsafe](https://forum.confluent.io/t/kafka-producer-transactions-threadsafe/37232)
**Author:** [@dbgtmaster](https://forum.confluent.io/u/dbgtmaster)\ **Replies:** 0\ **Last updated:** [13 February 2025 08:10 UTC](https://forum.confluent.io/t/kafka-producer-transactions-threadsafe/37232 "2025-02-13T08:10:32Z")
Hi, it is threadsafe, to use only one kafka producer instance in multiple threads and start transactions in multiple threads at the same time? I am using the python client. --- ## [Help getting started making Kafka act like a Queue](https://forum.confluent.io/t/help-getting-started-making-kafka-act-like-a-queue/37070)
**Author:** [@daelliott](https://forum.confluent.io/u/daelliott)\ **Replies:** 8\ **Last updated:** [6 February 2025 15:44 UTC](https://forum.confluent.io/t/help-getting-started-making-kafka-act-like-a-queue/37070 "2025-02-06T15:44:17Z")
I’m being told that I need to convert over from RabbitMQ to Kafka. With this in mind, I need to provide the same behavior as if I was working with a Queue. What I mean is, if I publish a message OrderShipped it should … --- ## [Error 13/13 brokers are down](https://forum.confluent.io/t/error-13-13-brokers-are-down/11477)
**Author:** [@sbezawada](https://forum.confluent.io/u/sbezawada)\ **Replies:** 0\ **Last updated:** [16 September 2024 15:36 UTC](https://forum.confluent.io/t/error-13-13-brokers-are-down/11477 "2024-09-16T15:36:36Z")
We are running Kafka 3.1.0 on Kubernetes using Strimzi and a C#(.NET) client that is connecting to this cluster. When the messages are published to the topic, the error message, “13/13 brokers are down”, getting reported… --- ## [AWS Confluent based layer for Lambda usage](https://forum.confluent.io/t/aws-confluent-based-layer-for-lambda-usage/8174)
**Author:** [@georgelza](https://forum.confluent.io/u/georgelza)\ **Replies:** 5\ **Last updated:** [11 September 2024 23:53 UTC](https://forum.confluent.io/t/aws-confluent-based-layer-for-lambda-usage/8174 "2024-09-11T23:53:01Z")
hi hi Does anyone have a zip file for a python: confluent client / import that they know works… Python 3.9 I’ve followed multiple examples and keep ending with the same result: “errorMessage”: “Unable to import modul… --- ## [Consuming with Airflow ConsumeFromTopicOperator](https://forum.confluent.io/t/consuming-with-airflow-consumefromtopicoperator/10858)
**Author:** [@mattmasuda](https://forum.confluent.io/u/mattmasuda)\ **Replies:** 1\ **Last updated:** [24 August 2024 02:10 UTC](https://forum.confluent.io/t/consuming-with-airflow-consumefromtopicoperator/10858 "2024-08-24T02:10:44Z")
Has anyone had success using Apache Airflow’s ConsumeFromTopicOperator to consume messages from a Confluent Cloud cluster? We are trying to get a basic consumer running in our Airflow environment but we keep running into… --- ## [Kafka producer ordering](https://forum.confluent.io/t/kafka-producer-ordering/11093)
**Author:** [@duttaab](https://forum.confluent.io/u/duttaab)\ **Replies:** 0\ **Last updated:** [18 July 2024 17:57 UTC](https://forum.confluent.io/t/kafka-producer-ordering/11093 "2024-07-18T17:57:50Z")
Hi, My apology if this is a question which is already been answered before. Use Case: I am reviewing an application (producer) which is using librdKafka as a 3rd party library to interact with Kafka brokers (3= 1L+2F).… --- ## [Battling to marshal & serialize struct into avro object](https://forum.confluent.io/t/battling-to-marshal-serialize-struct-into-avro-object/11062)
**Author:** [@georgelza](https://forum.confluent.io/u/georgelza)\ **Replies:** 2\ **Last updated:** [14 July 2024 11:46 UTC](https://forum.confluent.io/t/battling-to-marshal-serialize-struct-into-avro-object/11062 "2024-07-14T11:46:25Z")
Need some assistance, please. Made lots of cleanup, stuck on a avro.marshal step atm…if anyone can have a look, trying to redo my app (use to be Protobuf based) to be avro based as far as the kafka produce is concerned. … --- ## [Value not wanting to be serialised into protobuf](https://forum.confluent.io/t/value-not-wanting-to-be-serialised-into-protobuf/10907)
**Author:** [@georgelza](https://forum.confluent.io/u/georgelza)\ **Replies:** 5\ **Last updated:** [17 June 2024 17:06 UTC](https://forum.confluent.io/t/value-not-wanting-to-be-serialised-into-protobuf/10907 "2024-06-17T17:06:29Z")
Hi all… Need someone that has worked with protobuf, schema registry and Kafka using the confluent library stack. For the following git repo, cmd/producer.go I serialise the payload as per a couple of examples (Line 9… --- ## [Commit offsets with a new KafkaConsumer object in python](https://forum.confluent.io/t/commit-offsets-with-a-new-kafkaconsumer-object-in-python/10843)
**Author:** [@vijay.swd](https://forum.confluent.io/u/vijay.swd)\ **Replies:** 4\ **Last updated:** [12 June 2024 11:09 UTC](https://forum.confluent.io/t/commit-offsets-with-a-new-kafkaconsumer-object-in-python/10843 "2024-06-12T11:09:07Z")
Requirement I need to periodically (once a day) fetch messages from a Kafka topic and write all these messages to a Slack channel. Design I am using Temporal, an activity-workflow based model that implements resiliency.… --- ## [Info messages logged as errors](https://forum.confluent.io/t/info-messages-logged-as-errors/10681)
**Author:** [@bastinghe](https://forum.confluent.io/u/bastinghe)\ **Replies:** 0\ **Last updated:** [12 May 2024 14:00 UTC](https://forum.confluent.io/t/info-messages-logged-as-errors/10681 "2024-05-12T14:00:15Z")
We use kafkajs version 2.2.4 in our nestjs/node project to connect to Confluent cloud. The following messages shows up regularly in our logs as errors, although they look like info messages. This unnecessarily pollute ou… --- ## [Connection Issue using PEM Certificates with .NET](https://forum.confluent.io/t/connection-issue-using-pem-certificates-with-net/10539)
**Author:** [@aq101](https://forum.confluent.io/u/aq101)\ **Replies:** 0\ **Last updated:** [19 April 2024 16:23 UTC](https://forum.confluent.io/t/connection-issue-using-pem-certificates-with-net/10539 "2024-04-19T16:23:34Z")
Hi Everyone. I am new to using Confluent.Kafka and I have to connect to a Kafka instance at work using a .Net Client with PEM certificates. However when I do, the debug logs look like they immediately shut down the conne… --- ## [How can I reset the topic offset while consuming from Kafka topic](https://forum.confluent.io/t/how-can-i-reset-the-topic-offset-while-consuming-from-kafka-topic/10422)
**Author:** [@mdarende](https://forum.confluent.io/u/mdarende)\ **Replies:** 2\ **Last updated:** [21 March 2024 10:02 UTC](https://forum.confluent.io/t/how-can-i-reset-the-topic-offset-while-consuming-from-kafka-topic/10422 "2024-03-21T10:02:02Z")
Hello I start to consume from the last message of a Kafka topic with following code. What I want to do is: I want to consume the last 50 messages wait for 5 seconds and consume again the last 50 messages (The data i… --- ## [Consuming data from Kafka topic for a leight weight Live-Chart app. in .NET](https://forum.confluent.io/t/consuming-data-from-kafka-topic-for-a-leight-weight-live-chart-app-in-net/10421)
**Author:** [@mdarende](https://forum.confluent.io/u/mdarende)\ **Replies:** 0\ **Last updated:** [20 March 2024 11:19 UTC](https://forum.confluent.io/t/consuming-data-from-kafka-topic-for-a-leight-weight-live-chart-app-in-net/10421 "2024-03-20T11:19:34Z")
Hello In my lightweigt C# .NET app I have to visualise the data, of a Kafka topic in a simple live chart. Below I have listed the native requirements of my use case. Accordingly to that I am searching an easy way for co… --- ## [.NET Client on Android](https://forum.confluent.io/t/net-client-on-android/10374)
**Author:** [@Faris-Ahmed\_dhl](https://forum.confluent.io/u/Faris-Ahmed_dhl)\ **Replies:** 0\ **Last updated:** [12 March 2024 17:33 UTC](https://forum.confluent.io/t/net-client-on-android/10374 "2024-03-12T17:33:29Z")
Hi, I am trying to use .NET client on latest android version 14. My project compiles but at run time the kafka client fails to initialize librdkafka. I get this error: System.InvalidOperationException: \*\*Unsupported pl… --- ## [Is it possible to pass parameters to the underlying openssl lib?](https://forum.confluent.io/t/is-it-possible-to-pass-parameters-to-the-underlying-openssl-lib/10287)
**Author:** [@cnaggar](https://forum.confluent.io/u/cnaggar)\ **Replies:** 0\ **Last updated:** [29 February 2024 19:53 UTC](https://forum.confluent.io/t/is-it-possible-to-pass-parameters-to-the-underlying-openssl-lib/10287 "2024-02-29T19:53:26Z")
I have a use case where I have an inhouse intermediate CA issuing and signing all kafka keypairs for our mTLS setup. I need to be able to validate a certificate using the CA certificate of the intermediate CA alone. Wi… --- ## [Kafka Python Client performance](https://forum.confluent.io/t/kafka-python-client-performance/9002)
**Author:** [@eliad](https://forum.confluent.io/u/eliad)\ **Replies:** 1\ **Last updated:** [16 February 2024 09:42 UTC](https://forum.confluent.io/t/kafka-python-client-performance/9002 "2024-02-16T09:42:02Z")
Hello, Are there any performance benchmarks comparing the Confluent Kafka Python library with the Java version? I’m particularly interested in understanding any trade-offs regarding throughput, latency, and resource u… --- ## [Kafka data loss if connectivity breaks down](https://forum.confluent.io/t/kafka-data-loss-if-connectivity-breaks-down/10195)
**Author:** [@harmeet](https://forum.confluent.io/u/harmeet)\ **Replies:** 1\ **Last updated:** [16 February 2024 05:13 UTC](https://forum.confluent.io/t/kafka-data-loss-if-connectivity-breaks-down/10195 "2024-02-16T05:13:37Z")
Hello, We are facing issue in Kafka messages streaming if connectivity break down. Data is getting lost if connectivity break down or broker is not available. --- ## [C# - Is it possible to avoid metadata on consumer](https://forum.confluent.io/t/c-is-it-possible-to-avoid-metadata-on-consumer/10134)
**Author:** [@alfkato](https://forum.confluent.io/u/alfkato)\ **Replies:** 0\ **Last updated:** [12 February 2024 13:24 UTC](https://forum.confluent.io/t/c-is-it-possible-to-avoid-metadata-on-consumer/10134 "2024-02-12T13:24:05Z")
Hi! We are connecting to a customers Kafka. When we connect to the Bootstrapservers, we get a metadata answer back with brokers. These are internal addresses, so that when we try to consume, it does not work (As this add… --- ## [ksqlDB how to properly chunk data?](https://forum.confluent.io/t/ksqldb-how-to-properly-chunk-data/9944)
**Author:** [@xorlop](https://forum.confluent.io/u/xorlop)\ **Replies:** 3\ **Last updated:** [1 February 2024 17:48 UTC](https://forum.confluent.io/t/ksqldb-how-to-properly-chunk-data/9944 "2024-02-01T17:48:53Z")
I am trying to use ksqlDB with the REST API and a WSS (web socket server, to control authorization) which talks with React web app, but I am confused if I am going about it the right way: When I query a stream of dogs p… --- ## [Kafka Broker problem](https://forum.confluent.io/t/kafka-broker-problem/9847)
**Author:** [@pedro-silva](https://forum.confluent.io/u/pedro-silva)\ **Replies:** 0\ **Last updated:** [18 January 2024 08:58 UTC](https://forum.confluent.io/t/kafka-broker-problem/9847 "2024-01-18T08:58:37Z")
Hello team,I’m sorry if this isn’t the correct channel to post this question but I’m having some odd behavior in my Kafka dev cluster and I would like the help of the community to troubleshoot this situation: So I have a… --- ## [Dot Net 8 Compatibility?](https://forum.confluent.io/t/dot-net-8-compatibility/9705)
**Author:** [@BrettS](https://forum.confluent.io/u/BrettS)\ **Replies:** 0\ **Last updated:** [1 January 2024 12:34 UTC](https://forum.confluent.io/t/dot-net-8-compatibility/9705 "2024-01-01T12:34:25Z")
I am battling to upgrade a (working) Dot Net 6 Blazor app using Kafka to Dot Net 8. I am using NuGet “Confluent.Kafka v 2.3.0”. I am stuck on “Failed to resolve ‘kafka:9092’: Name or service not known”. Does anyone know … --- ## [Entity Framework Core provider for Apache Kafka](https://forum.confluent.io/t/entity-framework-core-provider-for-apache-kafka/8925)
**Author:** [@mariomastrodicasa](https://forum.confluent.io/u/mariomastrodicasa)\ **Replies:** 0\ **Last updated:** [23 October 2023 23:22 UTC](https://forum.confluent.io/t/entity-framework-core-provider-for-apache-kafka/8925 "2023-10-23T23:22:53Z")
Just released the first major version of Entity Framework Core provider for Apache Kafka. If anyone is interested in it can take a look to the the article on Medium describing how it works and its uses cases and the rele… --- ## [My KafkaConsumer is stuck in a Joining Group Loop](https://forum.confluent.io/t/my-kafkaconsumer-is-stuck-in-a-joining-group-loop/8733)
**Author:** [@jceddy](https://forum.confluent.io/u/jceddy)\ **Replies:** 0\ **Last updated:** [19 September 2023 19:44 UTC](https://forum.confluent.io/t/my-kafkaconsumer-is-stuck-in-a-joining-group-loop/8733 "2023-09-19T19:44:55Z")
I have a KafkaConsumer that is stuck in a “joining group” loop. It’s a simple Kafka Python consumer, here is the python script: from kafka import KafkaConsumer import logging import sys root = logging.getLogger('kafka… --- ## [Migration from kafka-python](https://forum.confluent.io/t/migration-from-kafka-python/8569)
**Author:** [@Mrigank11](https://forum.confluent.io/u/Mrigank11)\ **Replies:** 1\ **Last updated:** [18 September 2023 06:16 UTC](https://forum.confluent.io/t/migration-from-kafka-python/8569 "2023-09-18T06:16:40Z")
Is there any migration guide to move from kafka-python to confluent-kafka python library? I’m particularly looking at the equivalent alternates for the following in kafka-python: Config params: consumer\_timeout\_ms re… [Next page](https://forum.confluent.io/c/clients/non-java-clients/25.md?page=1)