只是kafka的新手
今天我在运行kafka-console-producer.sh的一些命令，我使用的是键值对消息
bin/kafka-console-producer.sh--主题生成器演示--属性"parse.key=true"--属性"；key.separator=："--经纪人名单kafka1:9092
我只是想知道在哪里可以找到生产者属性，就像我在
中搜索**"parse.key=true"**和**"key.separator=:"**一样https://kafka.apache.org/documentation/#producerconfigs
没有像这样的参数。这是一个自定义参数或预定义的参数，因为我必须更多地使用它，并且我可以应用于此命令
这些参数尤其不是Producer属性(与--producer-property一起传递，而不是与--property一起传递(。它们是CLI参数，实际上只能在源代码中找到。
您可以在ProducerConfig类中找到kafka生产者的所有属性
为了方便参考，让我列出kafka控制台生产者的可用参数。我希望你正在寻找这样的东西；
–batch-size <Integer: size>:-我们正在定义用于发送消息数量的单个批次–broker-list <String: broker-list>:-这是Kafka控制台-生产者的必需选项，形式为HOST:PORT的代理列表字符串–compression-codec [String: compression-codec]:-此选项用于压缩"none"或"gzip"。如果未指定值，则默认为"gzip–Help:–它将显示使用信息–metadata-expiry-ms<Long: metadata expiration interval>：以毫秒为单位的一段时间，在这段时间之后，即使我们没有看到任何领导层变动，我们也会强制刷新元数据。(默认值：300000(–producer-property <String: producer_prop>:-此参数用于将用户定义的属性设置为生产者的key=value对–producer.config<String: config file>:-这是包含与生产者相关的所有配置的属性文件–property <String: prop>:-此属性提供了将用户定义的属性传递给消息读取器的自由。这些属性允许自定义配置，并以key=value的形式进行定义–request-required-acks<String: request required acks>:-生产者请求所需的ack(默认值：1(–request-timeout-ms<Integer: request timeout ms>:-生产者Value的ack超时必须为非负且非零(默认值：1500(–Sync:–如果发送了一条集合消息，则对代理的请求是同步的，每次一个–timeout <Integer: timeouts>:-如果设置了，并且生产者正在异步模式下运行，这将给出消息排队等待足够批量大小的最大时间。该值以毫秒为单位–topic <String: topic>:-此选项是必需的。基本上，生成消息的主题id–Version:-显示Kafka版本