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)


相关推荐

  • 一步步学习Linux开发环境搭建与使用

    一步步学习Linux开发环境搭建与使用

  • pychrom激活码【在线破解激活】

    pychrom激活码【在线破解激活】,https://javaforall.cn/100143.html。详细ieda激活码不妨到全栈程序员必看教程网一起来了解一下吧!

  • oracle与mysql的存储区别_存储过程和触发器的区别和联系

    oracle与mysql的存储区别_存储过程和触发器的区别和联系1.创建存储过程语句不同oraclecreateorreplaceprocedureP_ADD_FAC(id_fac_cdINES_FAC_UNIT.FAC_CD%TYPE)asmysqlDROPPROCEDUREIFEXISTS`SD_USER_P_ADD_USR`;createprocedureP_ADD_FAC(id_fac_…

  • Unity AssetBundle介绍

    Unity AssetBundle介绍1.什么是AssetBundle?AssetBundle是一种资源压缩包。资源打包AssetBundle有两个好处:减小安装包的大小,资源可以在进入游戏时候,网络下载。 热更资源,方便修复线上资源问题引起的Bug,或新增加游戏内容。AssetBundle分为两种类型:场景AssetBundle&非场景AssetBundle。2.AssetBundle结构2.1As…

  • idea如何进行debug调试_idea debug怎么用

    idea如何进行debug调试_idea debug怎么用远程调试,特别是当你在本地开发的时候,你需要调试服务器上的程序时,远程调试就显得非常有用。JAVA支持调试功能,本身提供了一个简单的调试工具JDB,支持设置断点及线程级的调试同时,不同的JVM通过接口的协议联系,本地的Java文件在远程JVM建立联系和通信。此篇是IntellijIDEA远程调试的教程汇总和原理解释,知其然而又知其所以然。本机IntellijID…

  • 如何查看tomcat版本_tomcat修改端口号

    如何查看tomcat版本_tomcat修改端口号一、通过tomcat版本文件查看  找到tomcat目录,进入”xxx/tomcat/bin”目录,执行”shversion.sh”。如果没有设置JAVA_HOME和JRE_HOME环境变量则会报如下错误:[jieyu.ljy@tripco011182064160.na62xxx/tomcat/bin]$shversion.shNeithertheJAVA_HOMEn…

发表回复

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

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