我不知道该如何命名这个问题。但是我们有一个卡夫卡制片项目,它在日志上显示了这个警告。
o.a.k.clients.producer.ProducerConfig : The configuration 'internal.auto.downgrade.txn.commit' was supplied but isn't a known config.我们正在使用这种依赖关系:
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-stream-kafka</artifactId>
</dependency>在我们的pom.xml中,我们有一个春季吐露:
spring:
metrics:
export:
delay-millis: 10500
kafka:
producer:
retries: 10
buffer-memory: 33554432
cloud:
stream:
kafka:
bindings:
toInboundKafkaTopic-out-0:
producer:
configuration:
key:
serializer: org.apache.kafka.common.serialization.StringSerializer
binder:
requiredAcks: all
brokers: (removed)
bindings:
toInboundKafkaTopic-out-0:
destination: OutboundSink
content-type: application/json
source: toInboundKafkaTopic主要问题是如何解决日志中的警告消息?
发布于 2022-04-05 19:35:33
我需要知道我在评论中要求的版本,因为听起来你可能有一些错误的匹配。
我刚刚用2020.0.5建立了一个新的项目,它得到了spring-kafka 2.7.12与kafka-clients 2.7.2,而我不明白这个信息;只有当我将kafka-客户端更改为2.8.1时,我才能得到它。您应该让Boot为您管理版本,以便所有版本都对齐。
要么将kafka-客户端切换回2.7.2,要么将spring升级到2.8.4。
https://stackoverflow.com/questions/71698771
复制相似问题