当前位置: 首页 > 知识库问答 >
问题:

Apache Kafka的Spring:无法识别的生产者配置-'delivery.timeout.ms'

房育
2023-03-14

我有一个Spring引导应用程序,用于向Kafka集群上的主题发送消息。我已经自动拥有了delivery.timeout.ms的属性,在应用程序启动和生产者配置后,应用程序日志显示属性的值没有设置,并给出警告:"WARN[任务调度器-1]org.apache.kafka.clients.producer.producerConfig[]配置'delivery.timeout.ms'已提供,但不是已知的配置"

我已经检查了我的POM,并确认我使用了以下两个依赖项:

<dependency>
            <groupId>org.springframework.kafka</groupId>
            <artifactId>spring-kafka</artifactId>
            <version>2.2.2.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.apache.kafka</groupId>
            <artifactId>kafka-clients</artifactId>
            <version>2.1.0</version>
        </dependency>

我还确认该属性存在于2.1.0版中:https://kafka.apache.org/21/javadoc/org/apache/kafka/clients/producer/ProducerConfig.html

我看到一些帖子对其他房产发出了类似的警告,提到它可以被忽略;但是,我的应用程序遇到了不受欢迎的行为,可以通过根据其描述设置此属性来纠正。

共有1个答案

司寇安宜
2023-03-14

看起来你的Kafka客户端版本覆盖不起作用。我刚刚测试了它,它工作正常(与sping-kafka 2.2.9和2.1.1客户端):

ProducerConfig values: 
    acks = 1
    batch.size = 16384
    bootstrap.servers = [localhost:9092]
    buffer.memory = 33554432
    client.dns.lookup = default
    client.id = 
    compression.type = none
    connections.max.idle.ms = 540000
    delivery.timeout.ms = 123456
    enable.idempotence = false
    ...

尝试按照Spring for Apache Kafka参考手册中的说明覆盖所有Kafka客户端库。

 类似资料:
  • 我正在使用IntelliJ IDEA,并且Spring的所有插件都被激活了,但是当我加载我的Maven项目时,我遇到了以下错误: Spring配置检查 找到未映射的Spring配置文件。 请为模块配置/设置Spring刻面 有什么想法阻止它自动配置?

  • 我正在努力为Kafka-Streams正确配置Spring Cloud Stream,以便使用带有信任存储和密钥存储的SSL。 在我的应用程序中,我有多个流正在运行,所有流的SSL配置应该是相同的。 stream2:Topic2>Topic4 Topic3 stream3:Topic4>Topic5 我使用最新的Spring-Cloud Stream框架和Kafka-Streams以及Avro模型

  • 我正在尝试在我的Geb框架中设置log4j2。就我的一生而言,我不知道如何把这些结合起来。我有一个log4j2。使用记录器“Selenium”设置xml(不是log4j.xml)文件。在DefaultPage中,我尝试从配置文件。 log4j2.xml DefaultPage.groovy 测试执行并将输出写入STDERR,这是预期的,因为我有记录器。错误但是,它不支持日期的格式。此外,我还使用其

  • 问题内容: 我想把它放在我的pom.xml- 但收到此错误- 我的pom.xml- 问题答案: 您发布的摘录属于标记内。具体来说,它属于Apache Maven Jar插件内部。请参阅下面的示例,以了解您在做什么错。 请参阅此处的Apache Maven Jar插件文档:https : //maven.apache.org/plugins/maven-jar- plugin/index.html

  • 我看了一个教程,它解释了如何将RabbitMQ集成到Spring Boot应用程序中。在本教程中,(使用者)和(生产者)类位于同一个项目中。我想在两个不同的Spring Boot应用程序中实现它们。但是,由于类的原因,我无法将教程项目拆分为两个使用者项目和生产者项目。因为它耦合了(使用者)和(生产者)类。 如何实现和配置两个不同的cosnumer和producer Spring Boot应用程序?

  • 我已经使用注释配置了Spring Boot。我有以下文件:1)用于配置spring boot的AppStarter类