发布于2021-06-12 14:30 阅读(116) 评论(0) 点赞(19) 收藏(4)
Kafka是由Apache软件基金会开发的一个开源流处理平台,由Scala和Java编写
。Kafka是一种高吞吐量的分布式发布订阅消息系统
,它可以处理消费者在网站中的所有动作流数据。 这种动作(网页浏览,搜索和其他用户的行动)是在现代网络上的许多社会功能的一个关键因素。 这些数据通常是由于吞吐量的要求而通过处理日志和日志聚合来解决。 对于像Hadoop一样的日志数据和离线分析系统,但又要求实时处理的限制,这是一个可行的解决方案。Kafka的目的是通过Hadoop的并行加载机制来统一线上和离线的消息处理,也是为了通过集群来提供实时的消息
。
1.导入依赖
<dependency>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka</artifactId>
</dependency>
2.配置
spring:
kafka:
producer:
bootstrap-servers: ip:9092
consumer:
group-id: springboot-group1,springboot-group2
auto-offset-reset: earliest
发送定时任务:docker开启kafka+zookeeper
@Component
@EnableScheduling
public class KafkaSender {
//模板
@Autowired
private KafkaTemplate kafkaTemplate;
/**
* 定时任务 每隔一秒发送
*/
@Scheduled(cron = "00/1 * * * * ?")
public void send(){
String string = UUID.randomUUID().toString();
System.out.println(string);
//发送消息
ListenableFuture future = kafkaTemplate.send("mytest1", string);
future.addCallback(o -> System.out.println("成功"+string),throwable -> System.out.println("失败"+throwable));
}
}
作者:狗蛋来了
链接:http://www.javaheidong.com/blog/article/222146/d843f85311e8d36d81c5/
来源:java黑洞网
任何形式的转载都请注明出处,如有侵权 一经发现 必将追究其法律责任
昵称:
评论内容:(最多支持255个字符)
---无人问津也好,技不如人也罢,你都要试着安静下来,去做自己该做的事,而不是让内心的烦躁、焦虑,坏掉你本来就不多的热情和定力
Copyright © 2018-2021 java黑洞网 All Rights Reserved 版权所有,并保留所有权利。京ICP备18063182号-2
投诉与举报,广告合作请联系vgs_info@163.com或QQ3083709327
免责声明:网站文章均由用户上传,仅供读者学习交流使用,禁止用做商业用途。若文章涉及色情,反动,侵权等违法信息,请向我们举报,一经核实我们会立即删除!