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

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

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

• 如何配置Zookeeper安全机制（如何配置Zookeeper）
• 如何在DEDECM中生成静态页面？静态设置在哪里？
• Zookeeper日志管理的提示是什么（Zookeeper配置日志路径）
• 如何与Zookeeper实施数据同步（Zookeeper统一配置管理）
• 网络图形（实际TCP 3握手）（TCP 3握手SYN）

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