在生成消息时,被动Kafka Keep出现超时异常

w9apscun  于 2023-02-21  发布在  Apache
关注(0)|答案(1)|浏览(1907)

当试图产生关于Kafka的信息时,不断得到log:reactor.core.Exceptions$ErrorCallbackNotImplemented: org.apache.kafka.common.errors.TimeoutException: Topic topic not present in metadata after 60000 ms. Caused by: org.apache.kafka.common.errors.TimeoutException: Topic topic not present in metadata after 60000 ms.
已经确保我有Jackson核心,Jackson数据绑定和Kafka客户端依赖关系的生产者项目。此外,我如何通过安全协议在React堆KafkaSenderOptions

ycl3bljg

ycl3bljg1#

Topic topic not present in metadata after 60000 ms.您必须先创建主题,然后才能使用它-无论是通过命令行工具还是通过AdminClient
您可以在传递到create()的Map中设置任何ProducerConfig属性。

/**
     * Creates a sender options instance with the specified config overrides for the underlying
     * Kafka {@link Producer}.
     * @return new instance of sender options
     */
    @NonNull
    static <K, V> SenderOptions<K, V> create(@NonNull Map<String, Object> configProperties) {
        return new ImmutableSenderOptions<>(configProperties);
    }

相关问题