kafka topic key value

Kafka中的消息存储在topic中，每一条消息包含键值（key）和值（value）。 在Kafka中，可以使用Producer来向Kafka broker发送消息，而Consumer则是消息的使用方。

此外，Kafka还提供了"日志压缩"功能，可以通过这个功能来减少日志文件的大小。日志压缩功能可以在后台启动Cleaner线程池，定期将相同的key进行合并，只保留最新的value值。这对于消费者只关心key对应的最新value值的场景非常有用。

在Kafka中，消息的分发策略是根据key和partition机制来判断当前消息应该发送并存储到哪个partition中。可以根据需要进行扩展producer的partition机制。<span class="em">1</span><span class="em">2</span><span class="em">3</span>
#### 引用[.reference_title]
- *1* [Python操作分布式流处理系统Kafka](https://download.csdn.net/download/weixin_38752830/15461587)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v93^chatsearchT3_2"}}] [.reference_item style="max-width: 33.333333333333336%"]
- *2* [【kafka】原理解析](https://blog.csdn.net/u014227785/article/details/118314656)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v93^chatsearchT3_2"}}] [.reference_item style="max-width: 33.333333333333336%"]
- *3* [kafka基础](https://blog.csdn.net/zydbk/article/details/127247923)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v93^chatsearchT3_2"}}] [.reference_item style="max-width: 33.333333333333336%"]
[ .reference_list ]