Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.
Konfigurasi baca-saja broker ekspres
Amazon MSK menetapkan nilai untuk konfigurasi ini dan melindunginya dari perubahan yang dapat memengaruhi ketersediaan cluster Anda. Nilai-nilai ini dapat berubah tergantung pada versi Apache Kafka yang berjalan di cluster, jadi ingatlah untuk memeriksa nilai-nilai dari cluster spesifik Anda.
Tabel berikut mencantumkan konfigurasi read-only untuk broker Express.
| Properti | Deskripsi | Nilai Broker Ekspres |
|---|---|---|
| Broker.id | Id broker untuk server ini. | 1,2,3... |
| broker.rack | Rak broker. Ini akan digunakan dalam penugasan replikasi sadar rak untuk toleransi kesalahan. Contoh: `RACK1`, `us-east-1d` | ID AZ atau ID Subnet |
|
default.replikasi.faktor |
Faktor replikasi default untuk semua topik. |
3 |
| fetch.max.byte | Jumlah maksimum byte yang akan kami kembalikan untuk permintaan fetch. | Apache Kafka Standar |
| Group.max.size | Jumlah maksimum konsumen yang dapat ditampung oleh satu kelompok konsumen. | Apache Kafka Standar |
| inter.broker.nama pendengar | Nama pendengar yang digunakan untuk komunikasi antar broker. | REPLICATION_SECURE atau REPLIKASI |
| inter.broker.protocol.version | Menentukan versi protokol antar-broker mana yang digunakan. | Apache Kafka Standar |
| pendengar | Listener Comma-separated List - daftar URI yang akan kita dengarkan dan nama pendengar. Anda dapat mengaturadvertised.listeners property, tetapi bukan listeners properti. |
MSK-generated |
| log.message.format.versi | Tentukan versi format pesan yang akan digunakan broker untuk menambahkan pesan ke log. | Apache Kafka Standar |
min.insync.replika |
Ketika produsen menetapkan acks ke Anda dapat menggunakan nilai acks dari produsen Anda untuk menegakkan jaminan daya tahan yang lebih besar. Dengan mengatur acks ke “semua”. Ini memastikan bahwa produsen mengajukan pengecualian jika mayoritas replika tidak menerima tulisan. |
2 |
| nom.io.thread | Jumlah thread yang digunakan server untuk menghasilkan permintaan, yang mungkin termasuk disk I/O. (m7g.besar, 8), (m7g.xlarge, 8), (m7g.2xbesar, 16), (m7g.4xbesar, 32), (m7g.8xbesar, 64), (m7g.12xbesar, 96), (m7g.16xbesar, 128) | Berdasarkan jenis instance. = Math.max (8, 2* vCPU) |
| nom.network.thread | Jumlah thread yang digunakan server untuk menerima permintaan dari jaringan dan mengirim respons ke jaringan. (m7g.besar, 8), (m7g.xlarge, 8), (m7g.2xbesar, 8), (m7g.4xbesar, 16), (m7g.8xbesar, 32), (m7g.12xbesar, 48), (m7g.16xbesar, 64) | Berdasarkan jenis instance. = Math.max (8, vCPU) |
| replica.fetch.response.max.byte | Jumlah maksimum byte yang diharapkan untuk seluruh respons fetch. Rekaman diambil dalam batch, dan jika kumpulan rekaman pertama di partisi pertama yang tidak kosong dari pengambilan lebih besar dari nilai ini, kumpulan rekaman masih akan dikembalikan untuk memastikan kemajuan. Ini bukan maksimum mutlak. Pro message.max.bytes perti (config broker) atau max.message.bytes (config topik) menentukan ukuran batch rekaman maksimum yang diterima broker. |
Apache Kafka Standar |
| minta.timeout.ms | Konfigurasi mengontrol jumlah waktu maksimum klien akan menunggu tanggapan permintaan. Jika respons tidak diterima sebelum batas waktu berlalu, klien akan mengirim ulang permintaan jika perlu atau gagal permintaan jika percobaan ulang habis. | Apache Kafka Standar |
| transaksi.state.log.min.isr | min.insync.replicasKonfigurasi yang diganti untuk topik transaksi. |
2 |
| transaksi.state.log.replikasi.faktor | Faktor replikasi untuk topik transaksi. | Apache Kafka Standar |
unclean.leader.election.enable |
Mengizinkan replika yang tidak ada dalam set ISR untuk berfungsi sebagai pemimpin sebagai upaya terakhir, meskipun hal ini dapat mengakibatkan hilangnya data. |
SALAH |