Configuration de la bibliothèque 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.

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 le fichier d'exemple 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.