本地:使用aws msk群集和confluent.kafka nuget包时出现消息超时错误

cbeh67ev  于 2021-06-05  发布在  Kafka
关注(0)|答案(0)|浏览(279)

我有两个代理节点的aws-msk集群。我根本无法生成任何消息给代理程序总是得到本地消息:消息超时错误。
我可以使用aws cli正常访问集群集群集群节点没有任何身份验证只是应用程序应该在特定的aws vpc中运行
我尝试了最简单的例子,只是用aws集群节点替换引导服务器这里是代码

string brokerList = "b-1.8.c2.kafka.eu-central-1.amazonaws.com:9092,b-2.8.c.c2.kafka.eu-central-1.amazonaws.com:9092"; // sample nodes examples

string topicname=“测试主题”;

var config = new ProducerConfig { BootstrapServers = brokerList };

    using (var producer = new ProducerBuilder<string, string>(config).Build())
    {
        Console.WriteLine("\n-----------------------------------------------------------------------");
        Console.WriteLine($"Producer {producer.Name} producing on topic {topicName}.");
        Console.WriteLine("-----------------------------------------------------------------------");

        try
        {
            var deliveryReport = await producer.ProduceAsync(
                topicName, new Message<string, string> { Key = "MyKey", Value = "MyValue" });

            Console.WriteLine($"delivered to: {deliveryReport.TopicPartitionOffset}");
        }
        catch (ProduceException<string, string> e)
        {
            Console.WriteLine($"failed to deliver message: {e.Message} [{e.Error.Code}]");
        }

我尝试了tls和明文,它们都是集群中允许的,并且得到了相同的错误消息。
还要将集群配置从auto.create.topics.enable=false更改为auto.create.topics.enable=true,并且结果仍然相同。
我正在使用下面的配置设置
合流。Kafka裸体版。-confluent.kafka 1.4.3 apache kafka版本。-2.4.1
错误消息:本地:消息超时

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题