Konfiguration der Kinesis Producer Library - Amazon-Kinesis-Data-Streams

Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.

Konfiguration der Kinesis Producer Library

Die Standardeinstellungen reichen für die meisten Anwendungsfälle aus. Bei Bedarf können Sie aber auch das Verhalten von KinesisProducer an Ihre Bedürfnisse anpassen. Dazu kann beispielsweise eine Instance der KinesisProducerConfiguration-Klasse an den KinesisProducer-Konstruktor übergeben werden:

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

Sie können zudem eine Konfiguration aus einer Eigenschaftendatei laden:

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

Sie können jeden Pfad und jeden Dateinamen ersetzen, auf den der Benutzerprozess Zugriff hat. Sie können weitere SET-Methoden auf der so erstellten KinesisProducerConfiguration-Instance aufrufen, um die Konfiguration anzupassen.

Die Eigenschaftendatei sollte Parameter unter Verwendung ihrer Namen in angeben PascalCase. Die Namen stimmen mit denen überein, die in den SET-Methoden der KinesisProducerConfiguration-Klasse verwendet werden. Beispielsweise:

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

Weitere Informationen zu Nutzungsregeln und Wertlimits für Konfigurationsparameter finden Sie in der Beispieldatei mit Konfigurationseigenschaften auf GitHub.

Beachten Sie, dass nach dem Initialisieren von KinesisProducer eine Änderung der verwendeten KinesisProducerConfiguration-Instance keine weiteren Auswirkungen mehr hat. KinesisProducer unterstützt derzeit keine dynamische Neukonfiguration.