Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.
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. KinesisProducer
saat ini tidak mendukung konfigurasi ulang dinamis.