Configuration de la bibliothèque du producteur Kinesis - Amazon Kinesis Data Streams

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.

Configuration de la bibliothèque du producteur Kinesis

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.

Dans PascalCase, le fichier de propriétés doit spécifier les paramètres en indiquant leurs noms. Les noms correspondent à ceux qui sont utilisés dans les méthodes set de la classe KinesisProducerConfiguration. Exemples :

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 valeurs limite, consultez laExemple 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.