向主题发送消息时出现 KafkaProducerException

海滩古普塔

kafka 生产者的 Spring Boot 属性:

spring.kafka.bootstrap-servers=localhost:9092
spring.kafka.client-id=bam
#spring.kafka.producer.acks= # Number of acknowledgments the producer requires the leader to have received before considering a request complete.
spring.kafka.producer.batch-size=0
spring.kafka.producer.bootstrap-servers=localhost:9092
#spring.kafka.producer.buffer-memory= # Total bytes of memory the producer can use to buffer records waiting to be sent to the server.
spring.kafka.producer.client-id=bam-producer
spring.kafka.consumer.auto-offset-reset=earliest
#spring.kafka.producer.compression-type= # Compression type for all data generated by the producer.
spring.kafka.producer.key-serializer= org.apache.kafka.common.serialization.StringSerializer
#spring.kafka.producer.retries= # When greater than zero, enables retrying of failed sends.
spring.kafka.producer.value-serializer= org.apache.kafka.common.serialization.StringSerializer
#spring.kafka.properties.*= # Additional properties used to configure the client.

当我尝试向 kafka 主题发送消息时,出现以下异常:

Caused by: org.springframework.kafka.core.KafkaProducerException: Failed to send; nested exception is org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for bam-0 due to 30004 ms has passed since last append
at org.springframework.kafka.core.KafkaTemplate$1.onCompletion(KafkaTemplate.java:255)
at org.apache.kafka.clients.producer.internals.RecordBatch.done(RecordBatch.java:109)
at org.apache.kafka.clients.producer.internals.RecordBatch.maybeExpire(RecordBatch.java:160)
at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortExpiredBatches(RecordAccumulator.java:245)
at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:212)
at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:135)
... 1 more

由以下原因引起:org.apache.kafka.common.errors.TimeoutException:由于 30004 毫秒,bam-0 的 1 条记录自上次追加以来已过期

我无法弄清楚为什么我会收到此异常。有人可以帮忙吗?

海滩古普塔

发出通过设置解决advertised.listenersserver.properties成明文:// < ExternalIP >:9092。

注意:Kafka 是通过 aws 部署的。

本文收集自互联网,转载请注明来源。

如有侵权,请联系[email protected] 删除。

编辑于
0

我来说两句

0条评论
登录后参与评论

相关文章

来自分类Dev

向MSMQ发送消息时出现问题

来自分类Dev

从iOS向Kafka主题发送消息

来自分类Dev

使用java向kafka主题发送消息

来自分类Dev

fCM 向主题发送消息的速率远低于向设备发送消息的速率

来自分类Dev

向Microsoft团队聊天时发送消息时出现401错误

来自分类Dev

向所有用户发送的GCM消息(无主题)

来自分类Dev

使用 spring 集成网关向不同主题发送消息

来自分类Dev

通过Azure Java SDK将消息发送到Service Bus主题时出现500 Internal Server Error

来自分类Dev

尝试发送消息时出现UnhandledPromiseRejectionWarning

来自分类Dev

从 Celery 发送消息时出现 ActiveMQ 异常

来自分类Dev

向 HTTP 协议适配器发送消息时,为什么会出现 HTTP/1.1 503 Service Unavailable?

来自分类Dev

向TApplication发送消息

来自分类常见问题

向Kafka发送消息时需要密钥吗?

来自分类Dev

向其发送消息时将保留自身

来自分类Dev

通过lambda函数向SQS发送消息时如何插入

来自分类Dev

向50人发送消息时android应用崩溃

来自分类Dev

从码头向队列发送消息时出错(使用骆驼)

来自分类Dev

向 MQTT 中订阅相同主题的一些客户端发送消息

来自分类Dev

关于主题的ActiveMQ消息发送

来自分类Dev

关于主题的ActiveMQ消息发送

来自分类Dev

在向 Azure 主题发送消息之前重新创建主题客户端是否是一个好习惯

来自分类Dev

向PHP脚本发送请求时出现错误的符号

来自分类Dev

从Angular向Node发送参数时出现问题

来自分类Dev

向PHP脚本发送请求时出现错误的符号

来自分类Dev

Boost.Asio:发送太大消息时出现分段错误

来自分类Dev

使用python发送消息时出现错误400

来自分类Dev

向我发送消息时出现channel_not_found错误

来自分类Dev

使用PyAPNS发送推送消息时出现ssl.SSLError

来自分类Dev

使用PHP发送zip文件时出现空消息

Related 相关文章

  1. 1

    向MSMQ发送消息时出现问题

  2. 2

    从iOS向Kafka主题发送消息

  3. 3

    使用java向kafka主题发送消息

  4. 4

    fCM 向主题发送消息的速率远低于向设备发送消息的速率

  5. 5

    向Microsoft团队聊天时发送消息时出现401错误

  6. 6

    向所有用户发送的GCM消息(无主题)

  7. 7

    使用 spring 集成网关向不同主题发送消息

  8. 8

    通过Azure Java SDK将消息发送到Service Bus主题时出现500 Internal Server Error

  9. 9

    尝试发送消息时出现UnhandledPromiseRejectionWarning

  10. 10

    从 Celery 发送消息时出现 ActiveMQ 异常

  11. 11

    向 HTTP 协议适配器发送消息时,为什么会出现 HTTP/1.1 503 Service Unavailable?

  12. 12

    向TApplication发送消息

  13. 13

    向Kafka发送消息时需要密钥吗?

  14. 14

    向其发送消息时将保留自身

  15. 15

    通过lambda函数向SQS发送消息时如何插入

  16. 16

    向50人发送消息时android应用崩溃

  17. 17

    从码头向队列发送消息时出错(使用骆驼)

  18. 18

    向 MQTT 中订阅相同主题的一些客户端发送消息

  19. 19

    关于主题的ActiveMQ消息发送

  20. 20

    关于主题的ActiveMQ消息发送

  21. 21

    在向 Azure 主题发送消息之前重新创建主题客户端是否是一个好习惯

  22. 22

    向PHP脚本发送请求时出现错误的符号

  23. 23

    从Angular向Node发送参数时出现问题

  24. 24

    向PHP脚本发送请求时出现错误的符号

  25. 25

    Boost.Asio:发送太大消息时出现分段错误

  26. 26

    使用python发送消息时出现错误400

  27. 27

    向我发送消息时出现channel_not_found错误

  28. 28

    使用PyAPNS发送推送消息时出现ssl.SSLError

  29. 29

    使用PHP发送zip文件时出现空消息

热门标签

归档