기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.
Express 브로커 읽기 전용 구성
Amazon은 이러한 구성의 값을 MSK 설정하고 클러스터의 가용성에 영향을 미칠 수 있는 변경으로부터 보호합니다. 이러한 값은 클러스터에서 실행되는 Apache Kafka 버전에 따라 변경될 수 있으므로 특정 클러스터의 값을 확인해야 합니다. 여기 몇 가지 예가 있습니다.
| 속성 | 설명 | Express 브로커 값 |
|---|---|---|
| broker.id | 이 서버의 브로커 ID입니다. | 1,2,3... |
| broker.rack | 브로커의 랙입니다. 이는 내결함성을 위한 랙 인식 복제 할당에 사용됩니다. 예: `RACK1`, `us-east-1d` | AZ ID 또는 서브넷 ID |
|
default.replication.factor |
모든 주제에 대한 기본 복제 인자입니다. |
3 |
| fetch.max.bytes | 가져오기 요청에 대해 반환할 최대 바이트 수입니다. | Apache Kafka 기본값 |
| group.max.size | 단일 소비자 그룹이 수용할 수 있는 최대 소비자 수입니다. | Apache Kafka 기본값 |
| inter.broker.listener.name | 브로커 간 통신에 사용되는 리스너의 이름입니다. | REPLICATION_SECURE 또는 REPLICATION |
| inter.broker.protocol.version | 사용되는 인터 브로커 프로토콜의 버전을 지정합니다. | Apache Kafka 기본값 |
| 리스너 | 리스너 목록 - 리스너 및 리스너 이름을 수신할 쉼표로 구분된 목록URIs입니다. 를 설정할 수 advertised.listeners property있지만 listeners 속성은 설정할 수 없습니다. |
MSK-생성됨 |
| log.message.format.version | 브로커가 로그에 메시지를 추가하는 데 사용할 메시지 형식 버전을 지정합니다. | Apache Kafka 기본값 |
min.insync.replicas |
생산자가 acks를 생산자의 ack 값을 사용하여 더 높은 내구성을 보장할 수 있습니다. acks를 “all”로 설정합니다. 이렇게 하면 대부분의 복제본이 쓰기를 수신하지 못하는 경우 생산자가 예외를 발생시킵니다. |
2 |
| num.io.threads | 서버가 디스크 I/O(m7g.large, 8), (m7g.xlarge, 8), (m7g.2xlarge, 16), (m7g.4xlarge, 32), (m7g.8xlarge, 64), (m7g.12xlarge, 96), (m7g.16xlarge, 128)를 포함하여 요청을 생성하는 데 사용하는 스레드 수 | 인스턴스 유형에 따라 다릅니다. =Math.max(8, 2 * vCPUs) |
| num.network.threads | 서버가 네트워크에서 요청을 수신하고 네트워크에 응답을 전송하는 데 사용하는 스레드 수입니다. (m7g.large, 8), (m7g.xlarge, 8), (m7g.2xlarge, 8), (m7g.4xlarge, 16), (m7g.8xlarge, 32), (m7g.12xlarge, 48), (m7g.16xlarge, 64) | 인스턴스 유형에 따라 다릅니다. =Math.max(8, vCPUs) |
| replica.fetch.response.max.bytes | 전체 가져오기 응답에 대해 예상되는 최대 바이트 수입니다. 레코드는 배치로 가져오며 가져오기의 첫 번째 비어 있지 않은 파티션의 첫 번째 레코드 배치가 이 값보다 크면 진행을 보장하기 위해 배치가 반환됩니다. 이 값은 절대적인 최대값이 아닙니다. message.max.bytes (브로커 구성) 또는 max.message.bytes (주제 구성) 속성은 브로커가 수락하는 최대 레코드 배치 크기를 지정합니다. |
Apache Kafka 기본값 |
| request.timeout.ms | 구성은 클라이언트가 요청의 응답을 기다리는 최대 시간을 제어합니다. 제한 시간이 경과하기 전에 응답이 수신되지 않으면 필요한 경우 클라이언트가 요청을 다시 보내거나 재시도가 소진되면 요청에 실패합니다. | Apache Kafka 기본값 |
| transaction.state.log.min.isr | 트랜잭션 주제에 대해 재정의된 min.insync.replicas 구성입니다. |
2 |
| transaction.state.log.replication.factor | 트랜잭션 주제에 대한 복제 인수입니다. | Apache Kafka 기본값 |
unclean.leader.election.enable |
데이터 손실이 발생할 수 있더라도 ISR 세트에 없는 복제본이 마지막 수단으로 리더 역할을 하도록 허용합니다. |
FALSE |
