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/

總結

以上是生活随笔為你收集整理的eruka快速刷新和kafka配置(Eureka)的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。