View a markdown version of this page

Konfigurasi baca-saja broker ekspres - Amazon Managed Streaming untuk Apache Kafka

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 all (atau-1), nilai dalam min.insync.replicas menentukan jumlah minimum replika yang harus mengakui penulisan agar penulisan dianggap berhasil. Jika minimum ini tidak dapat dipenuhi, produsen mengajukan pengecualian (baik NotEnoughReplicas atauNotEnoughReplicasAfterAppend).

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