在哪里可以为Kafka的制作人设置确认？我可以在Kafka配置中的cloudera管理器中完成吗？或者有什么特别的方法可以完成吗？另外，如何查看已在使用的现有ack的值？我查过这里的文件了。但是，它没有说明如何/在何处设置这些选项。
bmp9r5qi1#
我认为文件很清楚。ack是producer配置参数，因此在应用程序中创建producer时，必须将“acks”属性设置为0、1或all，并且需要为properties包提供其所有参数（即bootstrap brokers list、key serializer、value serializer等）。ack不是一个与集群本身或特定代理相关的参数，而是一个与生产者相关的参数，这样您就可以拥有具有不同ack的不同生产者。
1条答案
按热度按时间bmp9r5qi1#
我认为文件很清楚。ack是producer配置参数，因此在应用程序中创建producer时，必须将“acks”属性设置为0、1或all，并且需要为properties包提供其所有参数（即bootstrap brokers list、key serializer、value serializer等）。ack不是一个与集群本身或特定代理相关的参数，而是一个与生产者相关的参数，这样您就可以拥有具有不同ack的不同生产者。