A. KafkaUtils.createStream(...)

B. StreamingContext.socketStream(..)

C. KafkaUtils.createDirectStream(...)

D. StreamingContext.fileStream(...)

A. 생산자는 메시지 생산자입니다.

B. Producer가 데이터를 생성할 때 먼저 ZooKeeper에 연결한 다음 Broker에 연결해야 합니다.

C. 여러 Producer 프로세스를 동시에 시작하여 동일한 주제에 데이터를 보낼 수 있습니다.

D. 생산자 생산 데이터는 주제를 지정해야 합니다.

A. 셔플 그룹화

B. 로컬 그룹화

C. 필드 그룹화

D. 직접 그룹화

A. 작업자의 수동 개입 없이 비정상 종료 후 감독자가 작업자를 자동으로 끌어올릴 수 있습니다.

B. Supervisor 프로세스가 종료된 후 실행 중인 비즈니스에 영향을 주지 않고 Nimbus에 의해 자동으로 인식되고 풀업될 수 있습니다.

C. Nimbus가 실패하면 실행 중인 비즈니스에 영향을 주지 않고 대기 Nimbus가 자동으로 인계됩니다.

D. 노드에 장애가 발생하면 해당 노드의 작업이 수동 개입 없이 다른 일반 노드에 재할당됩니다.

A. 사실

B. 거짓