Avatar notebook default
5篇文章 · 4952字 · 2人关注
  • storm整合kafka

    maven MyKafkaTopology bolt

  • Kafka java api-消费者代码

    1、消费者代码用到消费者,所以也必须先把前面写过的生产者代码也贴一下吧生产者代码与自定义partition使用maven导包 注:orderMq...

  • Kafka java api-生产者代码

    前面做过命令行让生产者发送消息,现在使用java api来进行消息的生产,以及解释kafka高性能是如何实现(来源于学习资料)。使用shell创...

  • Kafka集群部署与shell命令行操作

    1、kafka简介在流式计算中,Kafka一般用来缓存数据,Storm通过消费Kafka的数据进行计算。 KAFKA + STORM +REDI...

  • Resize,w 360,h 240
    kafka原理

    一、为什么需要消息系统 1.解耦:允许你独立的扩展或修改两边的处理过程,只要确保它们遵守同样的接口约束。2.冗余:消息队列把数据进行持久化直到它...

文集作者