CCDAK 문제 66
메시지 키가 있는 주제에 데이터를 생성하면 무슨 일이 달성됩니까?
CCDAK 문제 67
Apache Kafka를 가장 잘 설명하는 시스템 유형은 무엇입니까? (2개 선택)
CCDAK 문제 68
애플리케이션이 Kafka에서 메시지를 소비하고 있습니다. 애플리케이션 로그에서 파티션이 소비자 그룹에 자주 재할당되는 것을 확인할 수 있습니다.
어떤 요인이 이에 영향을 미칠 수 있을까요? (2개 선택)
어떤 요인이 이에 영향을 미칠 수 있을까요? (2개 선택)
CCDAK 문제 69
소비자가 토픽 topic1의 파티션 0과 1에서 메시지를 읽고 싶어합니다. 코드 조각은 아래와 같습니다.
소비자.구독(Arrays.asList("topic1"));
목록<TopicPartition> pc = 새 ArrayList<>();
pc.add(새로운 PartitionTopic("topic1", 0));
pc.add(새로운 PartitionTopic("topic1", 1));
소비자.할당(pc);
소비자.구독(Arrays.asList("topic1"));
목록<TopicPartition> pc = 새 ArrayList<>();
pc.add(새로운 PartitionTopic("topic1", 0));
pc.add(새로운 PartitionTopic("topic1", 1));
소비자.할당(pc);
CCDAK 문제 70
while (참) {
ConsumerRecords<String, String> 레코드 = consumer.poll(100);
노력하다 {
소비자.commitSync();
} catch (CommitFailedException e) {
log.error("커밋 실패", e)
}
(ConsumerRecord<String, String> 레코드 레코드)
{
System.out.printf("주제 = %s, 파티션 = %s, 오프셋
%d, 고객 = %s, 국가 = %s
",
기록.주제(), 기록.파티션(),
레코드.오프셋(), 레코드.키(), 레코드.값());
}
}
이 소비자는 어떤 종류의 배송 보장을 제공합니까?
ConsumerRecords<String, String> 레코드 = consumer.poll(100);
노력하다 {
소비자.commitSync();
} catch (CommitFailedException e) {
log.error("커밋 실패", e)
}
(ConsumerRecord<String, String> 레코드 레코드)
{
System.out.printf("주제 = %s, 파티션 = %s, 오프셋
%d, 고객 = %s, 국가 = %s
",
기록.주제(), 기록.파티션(),
레코드.오프셋(), 레코드.키(), 레코드.값());
}
}
이 소비자는 어떤 종류의 배송 보장을 제공합니까?