Configurazione della Kinesis Producer Library

Nonostante le impostazioni predefinite dovrebbero funzionare perfettamente per la maggior parte dei casi d'uso, è consigliabile modificare alcune delle impostazioni predefinite per adattare il comportamento di KinesisProducer alle proprie esigenze. Un'istanza di classe KinesisProducerConfiguration può essere passata al costruttore KinesisProducer per fare ciò, per esempio:

KinesisProducerConfiguration config = new KinesisProducerConfiguration()
        .setRecordMaxBufferedTime(3000)
        .setMaxConnections(1)
        .setRequestTimeout(60000)
        .setRegion("us-west-1");
        
final KinesisProducer kinesisProducer = new KinesisProducer(config);

Puoi anche caricare una configurazione da un file proprietà:

KinesisProducerConfiguration config = KinesisProducerConfiguration.fromPropertiesFile("default_config.properties");

Puoi sostituire qualsiasi percorso e nome di file al quale ha accesso il processo utente. Inoltre puoi chiamare metodi impostati sull'istanza KinesisProducerConfiguration creata in questo modo per personalizzare la configurazione.

Il file delle proprietà deve specificare i parametri usando i loro nomi in. PascalCase I nomi corrispondono a quelli utilizzati nei metodi impostati nella classe KinesisProducerConfiguration. Per esempio:

RecordMaxBufferedTime = 100
MaxConnections = 4
RequestTimeout = 6000
Region = us-west-1

Per ulteriori informazioni sulle regole di utilizzo dei parametri di configurazione e sui limiti di valore, vedere il file di esempio delle proprietà di configurazione su GitHub.

Nota che dopo che KinesisProducer è stato inizializzato, modificare l'istanza KinesisProducerConfiguration che è stata utilizzata non ha un effetto ulteriore. KinesisProducer non supporta al momento la riconfigurazione automatica.