Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.
Konfigurasi hanya-baca broker ekspres
Amazon MSK menetapkan nilai untuk konfigurasi ini dan melindunginya dari perubahan yang dapat memengaruhi ketersediaan klaster Anda. Nilai-nilai ini dapat berubah tergantung pada versi Apache Kafka yang berjalan di cluster, jadi ingatlah untuk memeriksa nilai dari cluster spesifik Anda. Berikut ini adalah beberapa contoh.
| 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-timur-1d` | ID AZ atau ID Subnet |
|
default.replication.factor |
Faktor replikasi default untuk semua topik. |
3 |
| fetch.max.bytes | Jumlah maksimum byte yang akan kami kembalikan untuk permintaan pengambilan. | Apache Kafka Standar |
| group.max.size | Jumlah maksimum konsumen yang dapat ditampung oleh satu kelompok konsumen. | Apache Kafka Standar |
| inter.broker.listener.name | Nama pendengar yang digunakan untuk komunikasi antar broker. | REPLICATION_ SECURE atau REPLICATION |
| inter.broker.protocol.version | Menentukan versi protokol antar-broker yang digunakan. | Apache Kafka Standar |
| pendengar | Listener List - Daftar dipisahkan koma dari URIs kita akan mendengarkan dan nama pendengar. Anda dapat mengaturadvertised.listeners property, tetapi bukan listeners properti. |
MSK-dihasilkan |
| log.message.format.version | Tentukan versi format pesan yang akan digunakan broker untuk menambahkan pesan ke log. | Apache Kafka Standar |
min.insync.replika |
Ketika produser 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 produser memunculkan pengecualian jika sebagian besar replika tidak menerima penulisan. |
2 |
| num.io.thread | Jumlah thread yang digunakan server untuk menghasilkan permintaan, yang mungkin termasuk disk I/O. (m7g.large, 8), (m7g.xlarge, 8), (m7g.2xlarge, 16), (m7g.4xlarge, 32), (m7g.8xlarge, 64), (m7g.12xlarge, 96), (m7g.16xlarge, 128) | Berdasarkan jenis instance. =Math.max (8, 2 *) vCPUs |
| num.network.threads | Jumlah thread yang digunakan server untuk menerima permintaan dari jaringan dan mengirim tanggapan ke jaringan. (m7g.large, 8), (m7g.xlarge, 8), (m7g.2xlarge, 8), (m7g.4xlarge, 16), (m7g.8xlarge, 32), (m7g.12xlarge, 48), (m7g.16xlarge, 64) | Berdasarkan jenis instance. =Math.max (8,) vCPUs |
| replica.fetch.response.max.bytes | Jumlah maksimum byte yang diharapkan untuk seluruh respons pengambilan. Rekaman diambil dalam batch, dan jika kumpulan rekaman pertama di partisi pengambilan yang tidak kosong pertama lebih besar dari nilai ini, kumpulan rekaman akan tetap dikembalikan untuk memastikan kemajuan. Ini bukan maksimum absolut. Properti message.max.bytes (konfigurasi broker) atau max.message.bytes (konfigurasi topik) menentukan ukuran batch catatan maksimum yang diterima broker. |
Apache Kafka Standar |
| request.timeout.ms | Konfigurasi mengontrol jumlah waktu maksimum klien akan menunggu respons permintaan. Jika tanggapan tidak diterima sebelum batas waktu berlalu, klien akan mengirim ulang permintaan jika perlu atau gagal permintaan jika percobaan ulang habis. | Apache Kafka Standar |
| transaction.state.log.min.isr | min.insync.replicasKonfigurasi yang diganti untuk topik transaksi. |
2 |
| transaction.state.log.replication.factor | Faktor replikasi untuk topik transaksi. | Apache Kafka Standar |
unclean.leader.election.enable |
Mengizinkan replika yang tidak ada di ISR set untuk berfungsi sebagai pemimpin sebagai upaya terakhir, meskipun ini dapat mengakibatkan hilangnya data. |
FALSE |
