sidsingh9

Hi @TsuyoshiUshio It seems this is not a problem with the certificate. - We are able to connect to local kafka(localhost) without any issue and getting all the messages -...

> We have a similar problem. Are you by any chance using Confluent Cloud to host the topics? No we use azure servers for our Apache Kafka

This is the host.json I was using { "version": "2.0", "logging": { "logLevel": { "Function.MyFunction": "Debug", "default": "Debug" } }, "extensions": { "kafka": { "MaxPollIntervalMs": 900000, "MaxBatchSize": 100, "AutoCommitIntervalMs": 200,...

Trid with extension version 3 as well [2021-04-20T15:09:30.060Z] Microsoft.Azure.WebJobs.Host.Config.IExtensionConfigProvider: Implementation: Microsoft.Azure.WebJobs.Extensions.Kafka.KafkaExtensionConfigProvider, Lifetime: Singleton [2021-04-20T15:09:30.060Z] Microsoft.Extensions.Options.IConfigureOptions`1[[Microsoft.Azure.WebJobs.Extensions.Kafka.KafkaOptions, Microsoft.Azure.WebJobs.Extensions.Kafka, Version=3.0.0.0, Culture=neutral, PublicKeyToken=null]]: Factory, Lifetime: Singleton [2021-04-20T15:09:30.060Z] Microsoft.Extensions.Options.IConfigureOptions`1[[Microsoft.Azure.WebJobs.Extensions.Kafka.KafkaOptions, Microsoft.Azure.WebJobs.Extensions.Kafka, Version=3.0.0.0, Culture=neutral, PublicKeyToken=null]]: Instance: Microsoft.Extensions.Options.ConfigureNamedOptions`1[[Microsoft.Azure.WebJobs.Extensions.Kafka.KafkaOptions,...

Some issue here with the offset. Since this was a new consumer group with no OFFSET stored i also tried running a console consumer with the same groupid to set...

[logsKafka-3.3.2.txt](https://github.com/Azure/azure-functions-kafka-extension/files/6348601/logsKafka-3.3.2.txt) Latest version log

yeah i tried the console consumer or a java consumer and it works. Will try to get the broker logs and see if there is anything weird there.

Kafka Version : 1.1.1 by console consumer i meant ~/Downloads/kafka_2.11-2.4.0/bin/kafka-console-consumer.sh --topic test --bootstrap-server kafka.prod-xxxxxx:9092

Tried a c# program with https://github.com/confluentinc/confluent-kafka-dotnet as well and its working fine

[2021-04-23T05:00:43.244Z] Libkafka: [thrd:main]: Group "azurefunctions123": unassign done in state up (join state wait-join): without new assignment: OffsetCommit done (__NO_OFFSET) [2021-04-23T05:00:43.445Z] Libkafka: [thrd:main]: OffsetCommit for -1 partition(s): cgrp auto commit timer:...