Konfigurasikan Perpustakaan Produser Kinesis

Meskipun pengaturan default harus berfungsi dengan baik untuk sebagian besar kasus penggunaan, Anda mungkin ingin mengubah beberapa pengaturan default untuk menyesuaikan perilaku dengan KinesisProducer kebutuhan Anda. Sebuah instance dari KinesisProducerConfiguration kelas dapat diteruskan ke KinesisProducer konstruktor untuk melakukannya, misalnya:

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

Anda juga dapat memuat konfigurasi dari file properti:

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

Anda dapat mengganti jalur dan nama file apa pun yang dapat diakses oleh proses pengguna. Anda juga dapat memanggil metode set pada KinesisProducerConfiguration instance yang dibuat dengan cara ini untuk menyesuaikan konfigurasi.

File properti harus menentukan parameter menggunakan nama mereka di PascalCase. Nama-nama cocok dengan yang digunakan dalam metode set di KinesisProducerConfiguration kelas. Sebagai contoh:

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

Untuk informasi selengkapnya tentang aturan penggunaan parameter konfigurasi dan batas nilai, lihat contoh berkas properti konfigurasi GitHub.

Perhatikan bahwa setelah KinesisProducer diinisialisasi, mengubah KinesisProducerConfiguration instance yang digunakan tidak memiliki efek lebih lanjut. KinesisProducersaat ini tidak mendukung konfigurasi ulang dinamis.