Configurar Kinesis Producer Library

Aunque la configuración predeterminada debería funcionar sin problemas para la mayoría de los casos de uso, es posible que desee cambiar algunos de los ajustes predeterminados para adaptar el comportamiento de KinesisProducer a sus necesidades. Para hacerlo, se puede pasar una instancia de la clase KinesisProducerConfiguration al constructor KinesisProducer, por ejemplo:

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

También puede cargar una configuración desde un archivo de propiedades:

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

Puede sustituir la ruta y el nombre de archivo a los que tiene acceso el proceso del usuario. También puede llamar a métodos fijos en la instancia KinesisProducerConfiguration que hayan sido creados así para personalizar la configuración.

El archivo de propiedades debe especificar los parámetros utilizando sus nombres en. PascalCase Los nombres han de coincidir con los utilizados en los métodos fijos de la clase KinesisProducerConfiguration. Por ejemplo:

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

Para obtener más información sobre las reglas de uso de los parámetros de configuración y los límites de valores, consulte el ejemplo del archivo de propiedades de configuración en GitHub.

Tenga en cuenta que después de inicializar KinesisProducer, los cambios en la instancia KinesisProducerConfiguration no tienen efecto alguno. Actualmente, KinesisProducer no admite la reconfiguración dinámica.