Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.
Bien que les paramètres par défaut fonctionnent en principe bien pour la plupart des cas d'utilisation, vous pouvez en modifier certains paramètres par défaut pour adapter le comportement de KinesisProducer
à vos besoins. Pour cela, une instance de la classe KinesisProducerConfiguration
peut être passée au constructeur KinesisProducer
, par exemple :
KinesisProducerConfiguration config = new KinesisProducerConfiguration()
.setRecordMaxBufferedTime(3000)
.setMaxConnections(1)
.setRequestTimeout(60000)
.setRegion("us-west-1");
final KinesisProducer kinesisProducer = new KinesisProducer(config);
Vous pouvez également charger une configuration à partir d'un fichier de propriétés :
KinesisProducerConfiguration config = KinesisProducerConfiguration.fromPropertiesFile("default_config.properties");
Vous pouvez remplacer un chemin d'accès et un nom de fichier auxquels le processus de l'utilisateur peut accéder. Vous pouvez aussi appeler les méthodes set sur l'instance KinesisProducerConfiguration
créée de cette façon afin de personnaliser la configuration.
Le fichier de propriétés doit spécifier les paramètres en utilisant leur nom dans PascalCase. Les noms correspondent à ceux qui sont utilisés dans les méthodes set de la classe KinesisProducerConfiguration
. Par exemple :
RecordMaxBufferedTime = 100
MaxConnections = 4
RequestTimeout = 6000
Region = us-west-1
Pour plus d'informations sur les règles d'utilisation des paramètres de configuration et les limites de valeurs, consultez l'exemple de fichier de propriétés de configuration sur GitHub
Notez que, une fois que KinesisProducer
est initialisé, la modification de l'instance KinesisProducerConfiguration
qui a été utilisée n'a aucun autre effet. KinesisProducer
ne soutient pas actuellement la reconfiguration dynamique.