이 페이지는 시험 연구소 브레인덤프 [ http://blog.examslabs.com ]에서 내보낸 페이지입니다.

내보내기 날짜:Sat Jan 4 4:06:21 2025 / +0000 GMT

___________________________________________________


제목: 교육 전문가가 알려주는 인증 가이드 Q&A로 CCDAK 문제 연습하기 [Q43-Q59]

---------------------------------------------------



 교육 전문가의 인증 가이드 Q&A로 CCDAK 문제를 연습하십시오.
무료 Confluent CCDAK 시험 연습 문제 시험 덤프


NO.43 소비자가 시작되고 auto.offset.reset=최신이고 주제 파티션에 현재 45에서 2311까지의 오프셋에 대한 데이터가 있습니다. 소비자 그룹은 이전에 토픽에 대해 오프셋 643을 커밋한 적이 있습니다. 소비자는 어디에서 읽을까요?
 충돌이 발생합니다.
 오프셋 2311
 오프셋 643
 오프셋 45
이 소비자 그룹과 토픽 파티션에 대해 오프셋이 이미 커밋되었으므로 auto.offset.reset 속성은 무시됩니다.44 log.cleanup.policy=compact를 설정하여 Kafka의 토픽에 대해 압축을 사용하도록 설정합니다. 로그 압축의 장점은 무엇인가요?
 정리 후에는 키당 하나의 메시지만 첫 번째 값으로 유지됩니다.
 토픽에 저장된 각 메시지는 압축됩니다.
 Kafka는 키 해시를 기반으로 수신 메시지의 중복을 자동으로 제거합니다.
 정리 후, 키당 하나의 메시지만 최신 값으로 유지됩니다.
압축은 메시지의 오프셋을 변경합니다. 설명: 로그 압축은 단일 토픽 파티션의 각 레코드 키에 대해 최소한 마지막으로 알려진 값을 유지합니다. 압축된 모든 로그 오프셋은 유효하게 유지되며, 오프셋의 레코드가 압축된 경우에도 소비자는 다음으로 높은 오프셋을 갖게 됩니다.NO.45 JDBC 소스 커넥터를 사용하여 테이블에서 Kafka 토픽으로 데이터를 복사하고 있습니다. 작업자 3명으로 구성된 클러스터에 최대 작업이 2인 커넥터 하나가 배포되어 있습니다. 몇 개의 작업이 시작되나요?
 3
 2
 1
 6
JDBC 커넥터는 테이블당 하나의 작업을 허용합니다.NO.46 토픽으로 전송된 메시지는 수정할 수 있습니다.
 아니요
 예
Kafka 로그는 추가 전용이며 데이터는 불변입니다.NO.47 다음 중 Avro 기본 유형이 아닌 것은?
 문자열
 long
 int
 날짜
 null
날짜는 논리 유형입니다.48 키가 포함되지 않은 토픽에 로그 메시지를 보내려는 Kafka 프로듀서 애플리케이션입니다. 프로듀서 구성에 대해 필수적으로 구성해야 하는 속성은 무엇인가요? (3개 선택)
 bootstrap.servers
 partition
 key.serializer
 value.serializer
 키
 value
키와 값 직렬화기는 모두 필수입니다.NO.49 다음 중 상태 비저장 이벤트 처리 애플리케이션은 무엇입니까? (두 개 선택)
 스트림에서 이벤트를 읽고 JSON에서 Avro로 수정합니다.
 매일 상위 10개 종목을 게시합니다.
 스트림에서 로그 메시지를 읽고 우선순위가 높은 스트림에 오류 이벤트를 쓰고 우선순위가 낮은 스트림에 나머지 이벤트를 씁니다.
 각 거래일의 최소 및 최대 주가 찾기
상태 비저장은 각 메시지의 처리가 메시지에만 의존한다는 의미이므로 JSON에서 Avro로 변환하거나 스트림을 필터링하는 것은 모두 상태 비저장 작업입니다.50 우리는 최대 한 번만 소모되는 시나리오에 있고 싶습니다. 어떤 오프셋 커밋 전략을 추천하시나요?
 데이터를 처리한 후 디스크에 오프셋을 커밋합니다.
 오프셋을 커밋하지 않고 처음부터 읽기
 데이터를 처리한 후 Kafka에서 오프셋을 커밋합니다.
 데이터를 처리하기 전에 Kafka에서 오프셋을 커밋합니다.
여기서는 .poll()에 대한 호출에서 배치를 받은 직후에 오프셋을 커밋해야 합니다.51 JDBC 소스 커넥터를 사용하여 2개의 테이블에서 2개의 Kafka 토픽으로 데이터를 복사하고 있습니다. 작업자 3명으로 구성된 클러스터에 배포된 최대 작업이 2인 커넥터가 하나 있습니다. 몇 개의 작업이 시작되나요?
 6
 1
 2
 3
테이블이 2개이므로 최대 작업 수는 2NO.52 6개의 브로커가 있고 파티션이 10개이고 복제 계수가 3인 토픽을 생성하기로 결정했다고 가정합니다. 0과 1 브로커는 랙 A에, 2와 3 브로커는 랙 B에, 4와 5 브로커는 랙 C에 있습니다.파티션 0의 리더가 브로커 4에 있고 첫 번째 복제본이 브로커 2에 있다면 마지막 복제본을 호스트할 수 있는 브로커는 어느 브로커입니까? (두 개 선택)
 6
 1
 2
 5
 0
 3
새 토픽을 생성하면 가용성을 유지하기 위해 파티션 복제본이 랙 전체에 분산됩니다. 따라서 현재 토픽 파티션을 보유하고 있지 않은 랙 A가 마지막 복제본으로 선택됩니다.53 로그 압축은 얼마나 자주 평가되나요?
 새 파티션이 생성될 때마다
 세그먼트가 닫힐 때마다
 메시지가 Kafka로 전송될 때마다
 메시지가 디스크로 플러시될 때마다
로그 압축은 세그먼트가 닫힐 때마다 평가됩니다. 충분한 데이터가 "더티"인 경우 트리거됩니다(더티 비율 구성 참조)NO.54 Kafka Streams에서 내부 토픽의 접두사는 어떤 값으로 지정되나요?
 작업-
 application.id
 group.id
 kafka-streams-
카프카 스트림에서, application.id는 소비자의 기본 group.id이기도 하며, 모든 내부 토픽(리파티션 및 상태)의 접두사입니다.NO.55 카프카 구성에서 auto.create.topics.enable가 true로 설정되면, 카프카 브로커가 토픽을 자동으로 생성하는 상황은 무엇인가요? (3개 선택)
 클라이언트가 토픽에 대한 메타데이터를 요청하는 경우
 소비자가 토픽에서 메시지를 읽음
 클라이언트가 토픽의 파티션 수를 변경하는 경우
 프로듀서가 토픽에 메시지를 보냅니다.
생산자가 토픽에 메시지를 쓰기 시작할 때 - 소비자가 토픽에서 메시지를 읽기 시작할 때 - 클라이언트가 토픽에 대한 메타데이터를 요청할 때 NO.56 토픽의 동적 구성은 어디에 저장되나요?
 Zookeeper에서
 내부 Kafka 토픽 __topic_configuratins에서
 server.properties
 Kafka 브로커 파일 시스템
동적 토픽 구성은 Zookeeper에서 유지 관리됩니다.NO.57 토픽은 커머스 사이트에서 사용 가능한 제품에 대한 모든 주문을 수신합니다. 두 개의 애플리케이션이 주문 처리와 모니터링이라는 모든 메시지를 독립적으로 처리하려고 합니다. 이 토픽에는 4개의 파티션이 있는데, 최적의 성능과 리소스 사용을 위해 소비자를 어떻게 구성할 수 있을까요?
 각 애플리케이션에 대해 4개의 소비자를 사용하여 동일한 그룹에 8개의 소비자를 만듭니다.
 두 애플리케이션에 대해 각각 8명의 소비자를 가진 두 개의 소비자 그룹을 생성합니다.
 두 개의 애플리케이션에 대해 각각 4명의 소비자를 가진 두 개의 소비자 그룹 만들기
 동일한 그룹에 4개의 소비자(각 파티션에 하나씩, 주문 처리용 2개 및 모니터링용 2개)를 생성합니다.
두 개의 파티션 그룹 - 모든 메시지가 두 애플리케이션에 모두 전달되도록 각 애플리케이션에 하나씩. 토픽의 파티션이 4개이므로 각각 4개의 소비자가 있으며, 그룹당 소비자를 파티션 수보다 많이 가질 수 없습니다(그렇지 않으면 비활성 상태가 되어 리소스가 낭비됨)NO.58 소비자가 시작되고 auto.offset.reset=none이며 토픽 파티션에는 현재 45에서 2311까지 오프셋에 대한 데이터가 있습니다. 소비자 그룹은 이전에 토픽에 대해 오프셋 10을 커밋한 적이 있습니다. 소비자는 어디에서 읽을까요?
 오프셋 45
 오프셋 10
 충돌합니다.
 offset 2311
auto.offset.reset=none은 복구하는 오프셋이 Kafka에서 삭제된 경우(여기서는 10 < 45NO.59) 소비자가 충돌한다는 의미입니다. 파티션의 복제본 중 하나 이상이 리더와 동기화되지 않은 모든 파티션을 어떻게 찾을 수 있을까요?
 kafka-topics.sh -bootstrap-server localhost:9092 -describe -unavailable- partitions
 kafka-topics.sh -zookeeper localhost:2181 -describe -unavailable- partitions
 kafka-topics.sh -bro