@Eduardo hahaha é que já vinha acompanhando há tempos, assim que lançou em 13 de julho passei uns 15 dias testando em alguns microsservicos em go e só sucesso, não foi do dia pra noite rsrs, só estou aguardando agora lançarem clients para nodejs, acredito que daqui pro final desse mês ou no próximo já tenha
Muito bacana Wesley sua explicação sobre o RabbitMQ. Gostaria que vc abordasse tb sobre o Apache Pulsar, uma outra alternativa para sistema de mensageria distribuída.
Se não me engano, com o rabbitmq, quando vc tem mais consumidores lendo uma fila, o primeiro consumidor a pegar a mensagem seta uma propriedade que informa que aquela mensagem já esta sendo utilizada, com isso os outros consumidores não pegam a mesma mensagem e assim não é processado a mesma informação varias vezes.
Wesley, primeiramente, obrigado pelo conteúdo aí. Me inscrevi aqui. Observação: Nas filas normais do Rabbit, tem um esquema de routing keys, que eu vejo como os consumers groups no mundo Kafka. Sera que pras fila tipo stream não tem essa possibilidade? Pergunta pra galera aí: O schema registry do Kafka não é só com Confluent Kafka?
Cara, eu não tenho seu contato. Mas sobre o client, esses clients novos são específicos, mas qualquer client AMQP consegue fazer qualquer operação com as streams, os clients novos são para não usar AMQP, já que AMQP tem diversos controles específicos de processamento, ack, etc coisas irrelevantes nas streams. Inclusive esses clients específicos operam em uma porta que não é a 5672. A gente está com o cara que construiu a feature no telegram, junto com o grupo que fundamos para tratar de RabbitMQ.
Falae Gago, blza? Sobre a comunicação via AMQP para mim está de fato claro que é possível, porém, eu não sei se nesse caso o protocolo permite andar pelos offsets, que é uma das principais vantagens de trabalhar com streams. Também o novo protocolo trabalha em formato binário, correto? De uma forma ou de outra, estou muito feliz de ter esse recurso rolando. Uso RabbitMQ na empresa e nos ajuda MUITO. =)
@@FullCycle permite Sim, está na doc. O offset é um dos parâmetros do consumo, fica no Basic Consume, é um dos parâmetros do dicionário/map que se envia ali.
O que ocorre esse ai vem bem a calhar pra mim que tenho um projeto de pedidos de venda mas nao quero expor meu sistema na internet entao posso atualizar este servico com os dados dos cliente bem resumido no caso cgc e nome razao social e a lista de produto por vendedor para atualizar os apps de venda e tambem receber os pedido no servico e baixalos no sistema posteriormente trazendo pra mim muito segurança no processo
Vejam o artigo do Luiz Carlos Faria dando mais detalhes sobre a entrada de streams no Rabbit:
gago.io/blog/streams-no-rabbitmq/
Meu amigo, Wesley manja muito... Tenho um bom conhecimento de devops tbm, mas sempre que sai algum vídeo aqui do canal, eu sempre aprendo algo novo
Estou utilizando o rabbitmq streams em prod, tá uma maravilha!
@Eduardo hahaha é que já vinha acompanhando há tempos, assim que lançou em 13 de julho passei uns 15 dias testando em alguns microsservicos em go e só sucesso, não foi do dia pra noite rsrs, só estou aguardando agora lançarem clients para nodejs, acredito que daqui pro final desse mês ou no próximo já tenha
Muito bacana Wesley sua explicação sobre o RabbitMQ. Gostaria que vc abordasse tb sobre o Apache Pulsar, uma outra alternativa para sistema de mensageria distribuída.
Muito legal! Obrigado por compartilhar :-)
Excelente vídeo Wesley parabéns sucesso.
Se não me engano, com o rabbitmq, quando vc tem mais consumidores lendo uma fila, o primeiro consumidor a pegar a mensagem seta uma propriedade que informa que aquela mensagem já esta sendo utilizada, com isso os outros consumidores não pegam a mesma mensagem e assim não é processado a mesma informação varias vezes.
Sim. O rabbitmq distribui as mensagens no modo round-robin (alternando cada consumidor) em filas comuns. Creio que deve ser o mesmo caso em streams
Muito bom! A briga está boa mesmo.
Sensacional, muito obrigado.
Wesley, primeiramente, obrigado pelo conteúdo aí. Me inscrevi aqui.
Observação: Nas filas normais do Rabbit, tem um esquema de routing keys, que eu vejo como os consumers groups no mundo Kafka. Sera que pras fila tipo stream não tem essa possibilidade?
Pergunta pra galera aí: O schema registry do Kafka não é só com Confluent Kafka?
Cara, eu não tenho seu contato. Mas sobre o client, esses clients novos são específicos, mas qualquer client AMQP consegue fazer qualquer operação com as streams, os clients novos são para não usar AMQP, já que AMQP tem diversos controles específicos de processamento, ack, etc coisas irrelevantes nas streams. Inclusive esses clients específicos operam em uma porta que não é a 5672. A gente está com o cara que construiu a feature no telegram, junto com o grupo que fundamos para tratar de RabbitMQ.
Falae Gago, blza?
Sobre a comunicação via AMQP para mim está de fato claro que é possível, porém, eu não sei se nesse caso o protocolo permite andar pelos offsets, que é uma das principais vantagens de trabalhar com streams. Também o novo protocolo trabalha em formato binário, correto? De uma forma ou de outra, estou muito feliz de ter esse recurso rolando. Uso RabbitMQ na empresa e nos ajuda MUITO. =)
@@FullCycle permite Sim, está na doc. O offset é um dos parâmetros do consumo, fica no Basic Consume, é um dos parâmetros do dicionário/map que se envia ali.
O que ocorre esse ai vem bem a calhar pra mim que tenho um projeto de pedidos de venda mas nao quero expor meu sistema na internet entao posso atualizar este servico com os dados dos cliente bem resumido no caso cgc e nome razao social e a lista de produto por vendedor para atualizar os apps de venda e tambem receber os pedido no servico e baixalos no sistema posteriormente trazendo pra mim muito segurança no processo
Fala @Full Cycle blz? Você presta consultoria? To precisando de uma luz das grandes rs
Vc tem cursos pra iniciantes?