什么是Kafka消息调整?

nor石

https://data-flair.training/blogs/advantages-and-disadvantages-of-kafka/中

众所周知,代理使用某些系统调用将消息传递给使用者。但是,如果需要调整邮件,Kafka的性能将大大降低。因此,如果消息不变,则它可以很好地执行,因为它使用了系统的功能。

如何调整消息?如果我想证明可以调整一条消息,该怎么办?

戈皮纳斯

声明中提到了对Kafka性能的怀疑。


怀疑:

如果消息需要调整,Kafka的性能将大大降低。因此,如果消息未更改,它可以很好地执行


澄清:

作为Kafka的用户多年,我发现Kafka保证,当消息在队列中时,不能更改该消息是其最佳功能之一。

Kafka不允许消费者直接更改队列中的机上消息(主题)。

消息内容可以在发布到主题之前或仅从主题使用之后进行更改。

可以使用以下多种主题来实现需要修改消息的业务需求:

(消息)->主题1 ->(消费和修改消息)->主题2

使用多个主题来实现消息修改功能只会增加存储需求它不会对性能产生任何影响。

Kafka不允许在运行中修改消息的设计提供了“数据完整性”这是在金融处理应用程序中广泛使用Kafka的背后驱动因素之一。

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

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

编辑于
0

我来说两句

0条评论
登录后参与评论

相关文章

来自分类Dev

为什么Kafka Consumer不断收到相同的消息(偏移)

来自分类Dev

重试Deadly Queue for Kafka中的消息的最佳实践是什么

来自分类Dev

Kafka 流合并消息

来自分类Dev

为什么kafka 0.10控制台生产者无法将消息发送到kafka 0.9?

来自分类Dev

Kafka:如果保留每个分区的顺序,那么在什么情况下主题消息会乱序

来自分类Dev

消费者为什么重启后会从Kafka主题中读取所有消息?

来自分类Dev

为什么Kafka消费者不听第一条消息?

来自分类Dev

当 kafka 服务器和生产者之间的连接断开时,消息会发生什么?

来自分类Dev

Kafka消息大小,激活压缩

来自分类Dev

为什么Kafka使用者外壳无法使用.Net Core控制台中我ProducerBuilder类的消息?

来自分类Dev

为什么Camel Kafka-Rabbitmq连接器将我的消息转换为不可读的格式?

来自分类Dev

为什么这个使用者(在servlet上运行)没有收到来自kafka主题的任何消息?

来自分类Dev

Spring Integration和Kafka:如何根据消息头过滤消息

来自分类Dev

Spring Boot Kafka消息消费者和丢失的消息

来自分类Dev

Kafka是否支持请求响应消息传递

来自分类Dev

将UDP消息推送到Kafka主题

来自分类Dev

Scala + Kafka不发送ID为的消息

来自分类Dev

Apache Kafka UnresolvedAddressException发送消息时

来自分类Dev

从Spark中的Kafka消息获取主题

来自分类Dev

在KAFKA中使用后删除消息

来自分类Dev

Kafka-如何观看新消息

来自分类Dev

过期的Apache Kafka消息未删除

来自分类Dev

删除Apache kafka中的主题消息

来自分类Dev

使用轮询模式使用Kafka消息

来自分类Dev

Apache Kafka-没有密钥的消息

来自分类Dev

Kafka-消息vs记录vs偏移

来自分类Dev

消耗来自Kafka主题的消息-无响应

来自分类Dev

Kafka主题返回0条消息

来自分类Dev

Kafka-python如何使用json消息

Related 相关文章

  1. 1

    为什么Kafka Consumer不断收到相同的消息(偏移)

  2. 2

    重试Deadly Queue for Kafka中的消息的最佳实践是什么

  3. 3

    Kafka 流合并消息

  4. 4

    为什么kafka 0.10控制台生产者无法将消息发送到kafka 0.9?

  5. 5

    Kafka:如果保留每个分区的顺序,那么在什么情况下主题消息会乱序

  6. 6

    消费者为什么重启后会从Kafka主题中读取所有消息?

  7. 7

    为什么Kafka消费者不听第一条消息?

  8. 8

    当 kafka 服务器和生产者之间的连接断开时,消息会发生什么?

  9. 9

    Kafka消息大小,激活压缩

  10. 10

    为什么Kafka使用者外壳无法使用.Net Core控制台中我ProducerBuilder类的消息?

  11. 11

    为什么Camel Kafka-Rabbitmq连接器将我的消息转换为不可读的格式?

  12. 12

    为什么这个使用者(在servlet上运行)没有收到来自kafka主题的任何消息?

  13. 13

    Spring Integration和Kafka:如何根据消息头过滤消息

  14. 14

    Spring Boot Kafka消息消费者和丢失的消息

  15. 15

    Kafka是否支持请求响应消息传递

  16. 16

    将UDP消息推送到Kafka主题

  17. 17

    Scala + Kafka不发送ID为的消息

  18. 18

    Apache Kafka UnresolvedAddressException发送消息时

  19. 19

    从Spark中的Kafka消息获取主题

  20. 20

    在KAFKA中使用后删除消息

  21. 21

    Kafka-如何观看新消息

  22. 22

    过期的Apache Kafka消息未删除

  23. 23

    删除Apache kafka中的主题消息

  24. 24

    使用轮询模式使用Kafka消息

  25. 25

    Apache Kafka-没有密钥的消息

  26. 26

    Kafka-消息vs记录vs偏移

  27. 27

    消耗来自Kafka主题的消息-无响应

  28. 28

    Kafka主题返回0条消息

  29. 29

    Kafka-python如何使用json消息

热门标签

归档