Kafka生产商组成中的关键点（Kafka生产者GroupID）是什么？

Bootstrap服务器：通过指定Kafka经纪人的地址列表来建立与Kafka群集的连接。 密钥序列化器：通过指定消息键的串行仪类，将密钥转换为字节流。
值序列化器：通过指定消息值的序列化类别将值转换为字节流。 Acks：指定生产者等待的确认级别。这是0（不等待确认），1（读取器确认）和所有（所有ISR确认）。 重试：发送消息失败时指定重试的数量。 批量尺寸：指定批处理中发送的消息的大小，以减少网络开销。
持续MS：指定在发送批处理消息之前等待多长时间，允许更多消息加入批处理。
缓冲记忆：指定生产者可以使用的最大内存量。
请求超时MS：指定生产者应等待的最长时间，然后才认为要失败的请求。 安全协议：指定与Kafka经纪人通信的安全协议，例如SASL_PLINTEXT，SSL等。 InterBroker侦听器名称：指定将用于与其他经纪人通信的侦听器名称。
消息键和值序列化器：除了基本密钥和值序列化器外，还可以配置其他序列化器，例如stringserializer，jsonserialializer等。

这几篇文章你可能也喜欢：

• 如何恢复Linux Crond中的悬挂任务
• KAFKA监视指标的重要参数是什么（Kafka队列监视）
• 您可以设置Linux Cron集的运行限制
• Linux CHMOD权限是什么意思？
• 如何优化Hadoop性能（Hadoop群集优化）

本文由主机参考刊发，转载请注明：Kafka生产商组成中的关键点（Kafka生产者GroupID）是什么？ https://zhujicankao.com/147409.html