eruka快速刷新和kafka配置

eruka快速刷新和kafka配置Kafkapartition扩充并且需要迁移数据生产不用指定具体分区,会自动分配拉取也不用指定具体分区,会自动拉多个分区可以同时拉取多个topickafka配置<dependency><groupId>org.apache.kafka</groupId><artifactId>kafka_2.12</artifactId><version>2.3.0</version>&lt…

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE使用 1年只要46元 售后保障 童叟无欺

Kafka partition扩充并且需要迁移数据
生产不用指定具体分区,会自动分配
拉取也不用指定具体分区,会自动拉多个分区

可以同时拉取多个topic 

kafka配置
<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka_2.12</artifactId>
    <version>2.3.0</version>
</dependency>
Properties proprops = new Properties();
proprops.put(“bootstrap.servers”, “192.168.31.234:59092”);
proprops.put(“acks”, “all”);
proprops.put(“key.serializer”, “org.apache.kafka.common.serialization.StringSerializer”);
proprops.put(“value.serializer”, “org.apache.kafka.common.serialization.StringSerializer”);

Producer<String, String> producer = new KafkaProducer<>(proprops);
for (int i = 0; i < 9999; i++)
    producer.send(new ProducerRecord<String, String>(“my-topic3”, Integer.toString(i), Integer.toString(i)));

producer.close();

Properties props = new Properties();
props.put(“bootstrap.servers”, “192.168.31.234:59092”);
props.put(“group.id”, “test6”);
props.put(“enable.auto.commit”, “true”);
props.put(“auto.commit.interval.ms”, “1000”);
props.put(“key.deserializer”, “org.apache.kafka.common.serialization.StringDeserializer”);
props.put(“value.deserializer”, “org.apache.kafka.common.serialization.StringDeserializer”);
//        props.put(“zookeeper.session.timeout.ms”, “40000”);
//        props.put(“zookeeper.sync.time.ms”, “200”);
//        props.put(“rebalance.max.retries”, “5”);
//        props.put(“rebalance.backoff.ms”, “12000”);
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
//        consumer.subscribe(Arrays.asList(“my-topic2”));
consumer.subscribe(Collections.singletonList(“my-topic3”));

while (true) {

    ConsumerRecords<String, String> records = consumer.poll(Duration.ofSeconds(5));
    System.out.printf(“2222222222222″+ records.toString());
    for (ConsumerRecord<String, String> record : records) {

        System.out.println(“llllllllllllllllll” + record);
        System.out.printf(“offset = %d, key = %s, value = %s%n”, record.offset(), record.key(), record.value());
    }
}

eureka 快速刷新配置

eureka:
  server:
    #关闭自我保护
    enable-self-preservation: false
    #不读取只读的缓存服务清单,因为30秒刷新一次比较慢,读写高速缓存过期策略
    UseReadOnlyResponseCache: false
    #启用主动失效,并且每次主动失效检测间隔为3s
    eviction-interval-timer-in-ms: 3000
  instance:
    hostname: localhost
    #服务过期时间配置,超过这个时间没有接收到心跳EurekaServer就会将这个实例剔除
    #注意,EurekaServer一定要设置eureka.server.eviction-interval-timer-in-ms否则这个配置无效,这个配置一般为服务刷新时间配置的三倍
    #默认90s
    lease-expiration-duration-in-seconds: 15
    #服务刷新时间配置,每隔这个时间会主动心跳一次
    #默认30s
    lease-renewal-interval-in-seconds: 5
  client:
    #客户端:服务缓存清单也是默认30秒更新一次,可通过设置RegistryFetchIntervalSeconds来缩短,单位是秒
    registryFetchIntervalSeconds: 5
    registerWithEureka: false
    fetchRegistry: false
    serviceUrl:
      defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/171858.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • pycharm交互式编程_环境影响因素有哪些

    pycharm交互式编程_环境影响因素有哪些讲解关于PycharmIDE当中一个叫做PythonConsole交互式开发环境。关于这个环境长什么样子以及怎么用,可以跟着我的步骤来看看。一、使用PythonConsole交互式开发环境打开Pycharm界面,然后单击界面最下面的PythonConsole这个按钮,单击后会调出一个控制台,这个控制台将自动加载已经调试过的解释器。在这个控制台里,程序员可以在三个绿色箭头>>>后面直接书写代码,在不加print的时候也行输出数据,当然print在这里也是可以用的。左边

  • Elasticsearch学习,请先看这一篇!

    题记:Elasticsearch研究有一段时间了,现特将Elasticsearch相关核心知识、原理从初学者认知、学习的角度,从以下9个方面进行详细梳理。欢迎讨论……0.带着问题上路——ES是如何产生的?(1)思考:大规模数据如何检索?如:当系统数据量上了10亿、100亿条的时候,我们在做系统架构的时候通常会从以下角度去考虑问题:1)用什么数据库好?(mysql、sybase、oracle、达

  • 电压电流转换检测「建议收藏」

    电压电流转换检测「建议收藏」电流可以转换成电压,电压也可以转换成电流。图十就是这样一个电路。上图的负反馈没有通过电阻直接反馈,而是串联了三极管Q1的发射结,大家可不要以为是一个比较器就是了。只要是放大电路,虚短虚断的规律仍然是符合的!由虚断知,运放输入端没有电流流过,则(Vi–V1)/R2=(V1–V4)/R6……a同理(V3–V2)/R5=V2/R4……b由虚短知V1=V2……c如果R2=R6,R4=R5,则…

  • 软件测试用例常用七大方法

    软件测试用例常用七大方法第一:测试用例格式包括十大特点用例编号测试项测试标题用例属性重要级别:高中低预置条件测试输入操作步骤预期结果实际结果第二:等价类1,等价类定义2,等价类划分3,等价类划分规则4,进行等价类用例设计5,案例加以说明第三:边界值1,边界值的三点2,边界值应用场景3,边界值方法应用步骤第四:判定…

  • whl文件下载「建议收藏」

    whl文件下载「建议收藏」到哪找.whl文件?http://www.lfd.uci.edu/~gohlke/pythonlibs/转载于:https://www.cnblogs.com/lhuser/p/8084734.html

  • Dll注入的问题

    Dll注入的问题学习游戏辅助,根据郁金香的教学视频写了Dll注入的代码,针对热血江湖进行Dll注入,失败(通过360任务管理器查看到Dll并未注入到游戏进程中)。但Dll中的SetWindowsHookEx返回值不为空,说明Hook成功?但是为啥没有注入成功呢?已经在游戏进程敲击键盘了【通过键盘钩子来实现Hook的】分析原因,先是反复检查代码,并未发现问题。后面想起来,是否因为是Dll是32位,而游戏是64位?查…

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号