Running your first Kafka Streams Application: WordCount

네 이제 핵심으로 들어가 보죠 첫 번째 카프카 림 앱을 실행할 거예요 코딩은 안 할 거예요 지금은 코드 분석은 안 할 거예요 어떻게 실행하고 뭘 하는지 보죠 카프카의 흐름이 높은 수준에서 어떻게 작용하는지 이해하세요 쉽게 소개할 수 있게요 네 먼저 카프카 쌍성을 다운로드하겠습니다 렌 듀프를 이용해 카프카를 실행하기 전에 다른 방식으로 실행할 테니까요 이 코스에서는 쌍성을 이용해 카프카를 공유할 거예요 두 사람의 작업 방식을 아는 게 중요해요 어떤 걸 더 좋아하는지 아는 것도요 기타 등등 이 일이 어떻게 돌아가는지 제대로 이해하는 게 중요해요 카프카의 사육사를 시작할 거예요 이 쌍성을 이용해서요 아주 쉬울 거예요 네 네 안 돼요 그런 다음 데이터를 입력 주제에 게시하겠습니다 단어 수를 세겠습니다 네 네 카프카와 함께 제공됐어요 WordCount는 말한 대로 하죠 문장에서 단어를 세는 거죠 이 예제를 살펴본 다음 출력 주제를 스트리밍할 겁니다 카프카 콘솔을 이용해서요 프로듀서 소비자 할 수 있다 할 수 있다 빼고 다 설명하는 거예요 예를 들어 쌍성을 이용해 카프카의 발사를 언급했죠 아주 쉽습니다 이미 직접 해봐야 해요 직접 해봐야 하는 과정이니까요 이미 뭔가 배울 수 있어요 그럼 시작하죠 구글에서 아파치 카프카를 입력하고 첫 번째 링크를 클릭하면 아파치 카프카 페이지로 전환돼요 , 아파치 카프카요 여기서 Apache Carfka를 다운로드 하세요 왼쪽 아래 버튼을 사용해서요 다운로드 후 0을 선택하는 게 정말 중요합니다 17살요 0 1점 이상으로요 0부터 11까지 선택하지 마세요 0 0개요, 안 그러면 다음 강의에서 이 첫 부분이 효과가 없을 거예요 어느 쪽이든 상관없지만 이 부분은 이걸 다운로드해 주세요 그러니 그렇게 해야 해요 이진법 다운로드도 가능해요 스칼라 211 212번 스칼라 하지만 웹페이지는 11까지 사용하길 권장합니다 첫 번째 링크를 클릭하겠습니다 여기서 카프카 쌍성을 다운로드 할 거예요 네 다른 코스에서 작업한 것과는 다른 접근법이지만 원시 쌍성을 직접 이용해 카프카를 어떻게 사용하는지 개요를 아는 건 좋아요 자, 갑니다 이 페이지에서 첫 번째 링크를 클릭하세요 여러분도 그래야 합니다 아파치 카프카를 다운로드 할 거예요 보시다시피 다운로드가 왼쪽 하단에 시작됐어요 네 이건 압축 아카이브예요 여러분이 해야 할 일은 좋아하는 도구를 이용해 압축을 푸는 거죠 ? 네 윈라나 일반 라인을 사용해도 되고요 아주 쉬워요 카프카를 다운로드하면 그걸 추출해 디렉터리에 들어가게 됩니다 그 디렉토리는 6개의 다른 것을 포함합니다 2개의 파일과 4개의 디렉토리입니다 네 라이선스 공지사항이 있고요 bin config lib와 사이트 문서들이 있네요 bin은 기본적으로 쌍성이 있는 곳이고 config는 구성이 있는 곳이죠 Libs는 자리의 종속성이 있는 곳이고 문서 내부는 그냥 문서입니다 네 이제 코드를 따라가 볼 거예요 이 강의 리소스로 다운로드할 수 있는 거요 기본적으로 첫 번째 카프카 스트림 앱을 실행할 겁니다 코드는 들어가지 않고 카프카 스트림 응용 프로그램의 결과와 출력은 살펴볼 겁니다 네 근데 여러분이 Windows 사용자라면 intro Windows 배치 파일을 사용하고 따라오세요 ???? 네 명령이 아주 아주 유사해요 이 비디오를 보세요 이 파일에 명령을 적용하세요 , 다른 것 대신에요 네 카프카를 등장시키기 전에 먼저 할 일은 사육사부터 시작하는 거예요 명령은 동물원 관리 서버 환경 설정 시작입니다 bin/동물원 사육사 서버 시작을 하는 이유는 동물원 사육사 스크립트가 위치하는 곳이기 때문입니다 이진 폴더에 있어요 마지막으로, 사육사에게 관심 있는 구성 요소는 이 파일입니다 네 자세히 설명하진 않겠지만 사육사에 관해 알고 싶다면 카프카 설정 코스를 확인하세요 사육사에 관해 더 알려드릴 수 있거든요 네 어쨌든 지금은 기본값이 괜찮아요 엔터를 누르면 보시는 것처럼 로그 출력이 나오죠 하지만 마지막에 보면 포트 2181에 제본하고 동물원 사육사가 시작돼요 잘됐네요 사육사가 나오면 다음 할 일은 카프카를 쉽게 시작하는 거였죠 빈 카프카 서버를 이용하죠 커맨드를 시작해 서버에 합류합니다 카프카의 속성이죠 이건 기본 기본 서버 또는 속성이에요 그걸 붙여넣기 하면 카프카가 시작되는 걸 보실 수 있죠 로그온도 있었어요 로그온 사육사도 있었고요 아래 우측에 카프카 서버가 시작됐다고 돼 있죠 카프카 버전은 0이에요 11시 01분에요 완벽해요 1이나 그 이상이라고 하세요 0에서 11까지는 안 돼요 00 네 카프카와 사육사가 시작됐어요 다른 껍데기들을 살펴볼게요 절대 오렌지 껍질에 봉하지 마세요 껍질을 봉하면 카프카나 사육사를 막을 수 있어요 네 항상 작동하게 해야 하니 문은 열어둬야죠 다른 두 개의 쉘에서 다른 명령을 실행하겠습니다 가장 먼저 해야 할 일은 스트림 응용 프로그램을 위한 입력 주제를 만드는 겁니다 아주 쉽네요 명령어를 복사해서 설명해 드릴게요 카프카 주제 명령을 다시 사용하죠 쓰레기통 목록에 있어요 네 마이너스 마이너스 창조 초보자 수업에서 봤던 것처럼 지역사회 1호 사육사 빼고 모든 분들을 위한 localhost 1입니다 1 복제 벡터와 파티션이 하나라 교육을 잘 시켜요 마지막으로 주제는 스트림 플레인텍스트 입력입니다 엔터를 누르면 주제가 만들어졌다는 반응을 받습니다 출력된 주제도 생성하도록 하겠습니다 카프카 스트림 앱에서 아주 중요한 건 미리 입력과 출력 주제를 생성하는 겁니다 안 그러면 앱이 이걸 안 해줄 거예요 이제 그 주제가 정말 만들어졌는지 확인할 수 있죠 bin에 대해 알아보죠 어느 편에 설지 정해야죠 그리고 마이너스를 합니다 마이너스 사육사 로컬 호스트 2-1-1-1- 리스트 보다시피 생성 중인 두 가지 주제는 전에 만든 겁니다 완벽해요 지금까진 좋아요 이제 데이터를 입력 주제에 게시할 겁니다 이것에 대해 콘솔 제작자로 시작할 거예요. 브로커 목록과 브로커 목록의 합의를 필요로 합니다. 브로커는 로컬 포스트 9092에 있습니다. 로컬 호스트는 120 7001과 정확히 같습니다 똑같은 일이 반복될 겁니다 마지막으로 특정 주제를 발표합니다 주제는 스트림 플레인텍스트 입력이죠 거기 가면 작은 화살표가 있는 걸 볼 수 있어요 입력될 데이터가 준비됐다는 뜻이죠 데이터를 입력해 볼게요. 카프카의 텍스트를 한 문장으로 입력할게요 카프카는 두 번째 문장을 처리하는 데이터를 보내고 카프카는 세 번째 문장을 보내요 그럼 계속하죠 카프카의 흐름 입력 카프카의 데이터 처리 입력 그리고 카프카의 흐름 여기서 나가려면 입력 Ctrl+C만 하면 끝나요 지금까진 괜찮죠? 네 그래서 이 텍스트에서 이미 보이는 건… 단어를 카운트하기 때문에 카프카가 세 번 나타나죠 스트림은 시간에 나타납니다 우디미가 한 번 데이터가 한 번 처리하는 게 한 번 코스가 한 번이죠 네 카프카는 3이 돼야 하고 스트림은 2가 돼야 하고 우데미 gb 1이 돼야 하고 이렇게 하면 돼요 정말 데이터가 공개됐는지 확인해 보죠 이에 대해 콘솔 소비자 부트스트랩 서버는 동일합니다 네 주제는 같지만 시작 깃발에서 마이너스-를 추가해 해당 주제의 모든 데이터를 페치할 거라고 합니다 엔터를 누르면 보시는 것처럼 데이터가 검색됐습니다 ? 카프카는 우리 데이터를 갖고 있어요 소비자는 장기 실행 프로세스니까요 막아야 하고 막아야 해요 세 개의 메시지를 모두 처리하라고 하죠 정말 멋지죠? 입력 주제는 데이터입니다 이제 프로세스를 진행하면 됩니다 하지만 그 전에 출력된 주제에서 소비자를 시작하겠습니다 명령을 복사해서 설명해 드릴게요 오른쪽을 복사해 놓을게요 네 기본적으로 소비자를 시작하는데 전에 했던 것보다 약간 더 복잡해졌죠 예를 들어 저 명령은 엔진의 로컬호스트에 있는 부트스트랩 서버에 연결됩니다 주제는 스트림 워드 카운트 출력이죠 처음부터 할 계획인 상위 주제입니다 네 전에 봤었죠 포맷터가 있어요 포맷터는 기본적으로 키의 값과 콘솔에 있는 값의 값을 줍니다 ??? 크게 걱정할 건 없지만 이 차이는 중요합니다 왜냐하면 로그에 프린트된 키와 값을 볼 수 있기 때문입니다 우리가 원하는 거죠 엔터를 누르면 콘솔 소비자가 시작됐는데 아직 작성된 데이터가 없기 때문에 출력 주제에 대해서요 아무것도 안 보여요 이제 마법 같은 순간입니다 스트림 앱을 시작할 때요 이걸 시작합니다 빈 카프카 런 클래스 맞아요 M 카운트라는 단어가 나오죠 O 명령어를 복사하는 것입니다 제가 엔터를 누르면 오른쪽에 무슨 일이 일어나는지 잘 보세요 갑니다 보다시피 단어 카운트 응용 프로그램은 여전히 실행 중입니다 오른쪽에는 많은 정보가 인쇄됐어요 카프카 스트림의 응용 프로그램의 결과물이죠 그럼 출력을 보죠 첫 번째는 카프카 1편이에요 그리고 스트리밍 1과 못된 짓 뉴가 있어요 기본적으로 이 카프카 1과 일치하죠 스트리밍 1과 우데미 1이요 응용 프로그램이 이 한 문장을 보세요 카프카도 등장하고요 네 카프카 앱이 카프카를 읽어서 이미 카프카 1을 만났기 때문이죠 , 카프카 2라고 쓰여 있어요 그러면 데이터와 프로세싱이 따로따로 옵니다 드디어 카프카를 잡겠네요 그 전에 2였으니 3이죠 그럼 스트리밍이 4가 될 수 없어요 이제 2가 나왔네요 저는 그리고 당연히 1번이죠 고전적인 단어지만 쭉 이어져 내려왔어요 모든 계산이 카프카로 밀렸다는 뜻이죠 정말 멋져요 네 이제 제가 할 수 있는 건 Ctrl C와 제 컨트롤을 해서 카프카 스트림의 응용 프로그램을 멈추는 거죠 소비자 자, 갑니다 네 방금 9개의 메시지를 읽었어요 각각의 메시지는 제 스트리밍 계산의 업데이트였죠 카프카 스트림 앱에 대해서요 그건 정말 정말 정말 멋져요 ? 네 자 여기서 한 걸 요약하자면 기본적으로 주제를 만들었어요 입력 주제요 출력 주제를 생성합니다 그런 다음 카프카 스트림 어플리케이션을 실행해 자동으로 스트림 방식으로 워드 수를 생성했어요 실시간으로 한 거예요 정말 멋졌어요 네 한 번이 아니었어요 복합적인 경우라면 3번 카프카만 나왔을 거예요 2번이나 1번은 안 나왔죠 1번 카프카는 안 나왔어요 그게 카프카의 힘이죠 이상하네요 여기서 스트리밍을 할 수 있어요 마지막으로 주목해 주실 게 있습니다 네 카프카 주제 명령어를 다시 해 주제 목록을 보면 더 많은 게 보이죠 네 소비자의 불만이 있어요 소비자가 있으니까요 하지만 스트림 워드 카운트 로그 변경, 스트림 워드 카운트 카운트 레파티션 그게 뭐냐고 물으면 이렇게 대답하죠 이건 카프카의 내부 개울이에요 토픽과 카프카 스트림이 만들어집니다 계산에 근거해서요 관리할 필요는 없지만 기본적으로 좋은 데이터가 많이 들어 있어요 카프카 스트림이 마법을 부리게 해주는 데이터요 X 섹션보다 더 자세히 이해하게 될 거예요 네 하지만 카프카의 개울이 어떻게 작동하는지 맛보기를 보여드리고 싶었어요 어떻게 사용되고 어떻게 할 수 있는지요 기대하셔도 좋아요 전무라는 말이 마음에 드셨으면 좋겠네요 곧 다시 뵙죠