1 package com.bawei.stream 2 3 import org.apache.kafka.clients.consumer.ConsumerRecord 4 import org.apache.kafka.common.serialization.StringDeserializ ...
分类：
其他好文 时间：
2020-05-05 17:51:00
阅读次数：
59
1 package com.bawei.review01 2 3 import java.net.InetSocketAddress 4 5 import org.apache.kafka.clients.consumer.ConsumerRecord 6 import org.apache.kaf ...
分类：
其他好文 时间：
2020-05-05 17:47:17
阅读次数：
55
idea Debug 报错 : Method breakpoints may dramatically slow down debugging debug 被卡住 打开Breakpoints面板看看，(快捷键：Ctrl - Shift -F8 ),将 java Method Breakpoints ...
分类：
其他好文 时间：
2020-05-05 10:30:25
阅读次数：
53
一.什么是feign 之前使用ribbon作为负载均衡来进行实现consumer调用provider，这种调用模式需要去借助restful风格(RestTemplate)，这种调用方式违背了程序员的思维。 后来springcloud提供了另外一种符合程序员思维的调用方式： 声明式服务调用(Feign ...
分类：
其他好文 时间：
2020-05-05 09:14:50
阅读次数：
74
一、思路 一般在开发过程中：生产者工程：1. application.yml文件配置RabbitMQ相关信息；2. 在生产者工程中编写配置类，用于创建交换机和队列，并进行绑定3. 注入RabbitTemplate对象，通过RabbitTemplate对象发送消息到交换机消费者工程：1. applic ...
分类：
编程语言 时间：
2020-05-04 19:33:25
阅读次数：
79
创建两个工程，一个是nacos-provider, 另一个是naocos-consumer； 添加nacos-provider的依赖 <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starte ...
分类：
其他好文 时间：
2020-05-03 14:36:21
阅读次数：
61
// 它们定义在 System.Character, 它可以彻底替代同单元的 TCharacter 结构体. 主要方法有: function IsControl: Boolean; function IsDigit: Boolean; function IsHighSurrogate: Boolea ...
//使用kafka+sparkStreaming进行数据处理 //从kafka拉取数据 package com.swust.predict import org.apache.kafka.clients.consumer.ConsumerRecord import org.apache.kafka. ...
分类：
其他好文 时间：
2020-05-02 23:22:17
阅读次数：
114
1.消费者用--bootstrap-server方式启动，消费的偏移量offset保存在broker的一个主题_consumer_offsets里，此主题默认50个分区。 2.zk中的version-2文件夹存储了关于kafka的一些数据。 3.server.properties里的log.dir项 ...
分类：
其他好文 时间：
2020-05-02 23:17:21
阅读次数：
117
Ribbon可以整合整合断路器监控HystrixDashboard，Feign也不能少,本篇讲解一下Feign如何整合断路器监控HystrixDashboard。本篇主要整合sc-eureka-client-consumer-feign-hystrix项目和sc-hystrix-dashboard项目。1、新建项目sc-feign-hystrix-dashboard，对应的pom.xml文件如下&
分类：
其他好文 时间：
2020-05-02 09:49:56
阅读次数：
58
