发布到红熊猫代理时不可用的代理

Question

当我试图向红熊猫代理发布一条消息时，我会得到错误The broker is not available.。我用的是Sarama Go Kafka的客户。下面是我如何创建生产者并发布一条消息：

kafkaConfig := sarama.NewConfig()
kafkaConfig.Producer.Return.Successes = true
producer, err := sarama.NewSyncProducer(brokerList, kafkaConfig)

if err != nil {
    log.Fatalf("NewSyncProducer failed: %s", err)
    return nil, err
}

message := sarama.ProducerMessage{Topic: "my-topic", Value: sarama.ByteEncoder([]byte("foo"))}

partition, offset, err := producer.SendMessage(&message)

if err != nil {
    log.Errorln(err)
}

err包含kafka server: Broker not available. Not a client facing error, we should never receive this!!!

在systemctl日志中，我在发布消息时看到了这一点：

WARN  2022-11-21 17:53:23,148 [shard 3] kafka - [127.0.0.1:46790] rejecting produce request: no disk space; bytes free less than configurable threshold
ERROR 2022-11-21 17:53:25,941 [shard 0] cluster - (rate limiting dropped 359 similar messages) storage space alert: free space at 18.208% on /var/lib/redpanda/data: 23.517GiB total, 4.282GiB free, min. free 0.000bytes. Please adjust retention policies as needed to allow writing again

是什么设置控制了这个阈值？

Answer 1

@user2233706 -您需要首先创建主题。否则，请确保etc/red熊猫/redanda.yaml将自动创建主题设置为true。