Olá pessoal, eu me chamo Ronaldo Lanielas e nessa aula eu vou mostrar como criar um conector sync que grava no arquivo. Se vocês lembrarem, na aula passada a gente deixou um conector source rodando que lê do Postgre e salva no Kafka. Então aqui a gente tem o tópico, tem as mensagens, está tudo aqui. Agora vou fazer o outro caminho, então vou ler desse tópico que o Postgre está salvando e vou gravar no arquivo. Então a primeira coisa que eu vou fazer é baixar um conector sync. vou baixar um conector sync eu gosto do camel então se for aqui instale ele configuration conector list cadê o conector list, cadê o conector list aqui? acho que eu tenho aqui camel-file você vai ver que ele tem esse conector que ele é tanto o sync como o source. Eu vou baixar aqui ele. Vou abrir a documentação sync dele. Primeiro eu vou copiar o plugin. Por enquanto, se vocês vocês lembrarem eu só tenho o JDBC instalado, então vou mover na verdade, eu tenho aqui o camera e vou extrair ele aqui. Lembrando que eu preciso restartar o cluster para o plugin ser reconhecido, então vou dar um restart aqui no Kafka Connect. Enquanto ele está restartando, a gente pode começar a criar aqui o nosso conector sync então eu vou remover isso aqui que era do nosso source o conector class vai mudar, vai ser camel agora eu vou chamar de sync camel file eu preciso da minha propriedade tasks.max Lembra que eu preciso desse carinha aqui. Eu preciso também, lembra que esse conector é um conector sync, então eu preciso dizer qual é o tópico que ele vai ler. No caso vai ser o Laniéla's client. E aí entram as propriedades do plug-in. Olhando aqui na página do Camel, eu só tenho essa que é obrigatória. Se eu olhar as outras aqui, não tem nenhuma outra required. Então eu vou colocar só essa aqui. E no meu diretório, lembra que eu estou rodando num docker, então eu tenho um data lá e eu vou criar um diretório output, onde vai ficar todos os meus arquivos. Aqui no meu data eu preciso criar esse diretório output. Então vou até só sair daqui, está vazio, não tem nada. E vou criar, então vamos criar aqui. Vamos ver qual é o status desse conector. Está running. Se a gente olhar aqui na carga Q, ele está verdinho, então ele já até consumiu essa mensagem que estava aqui. Então, está aqui. Quer criar um arquivo com esse conteúdo. Se eu mandar um outro registro, aqui é o 8, eu vou colocar o 9 aqui e vamos ver se chegou um arquivo aqui. aqui chegou um outro arquivo certo se você tiver o jq você pode formatar e aí conforme eu for mandando vou dar um watch aqui conforme eu for mandando mais registro então vou mandar o 10 agora aqui vai perceber que vão chegando novos arquivos aqui no meu diretório de output, está vendo? Vou mandar mais um. Então, o que aconteceu? Eu inseri um dado no banco O Kafka Connect Source JTBBC leu do banco Gravou no Kafka Eu tenho outro conector Que está lendo desse mesmo tópico E está gravando no meu diretório de output Certo? Era isso pessoal, espero que vocês tenham gostado