首頁(yè) 猿問(wèn) Java在源碼中設(shè)置Kafka保留時(shí)間

Java在源碼中設(shè)置Kafka保留時(shí)間

Java

蠱毒傳說(shuō) 2023-10-12 16:42:34

我有以下問(wèn)題。我需要在 Kafka 中為某些選定的主題設(shè)置保留時(shí)間。我找到了一個(gè)解決方案，可以使用以下命令進(jìn)行設(shè)置：kafka-topics --zookeeper localhost:2181 --alter --topic topic-name --config retention.ms=-1我檢查了 Kafka 的 Web UI 并確認(rèn)它已更改。如果可能的話，我想自己在Java中設(shè)置保留時(shí)間，但我似乎找不到合適的類/配置來(lái)設(shè)置時(shí)間。我以為我可以在 ProducerConfig 類中獲取有關(guān)保留的信息，但我在那里找不到它。是否可以在 Java 中設(shè)置保留時(shí)間？如果可以，我該如何完成？提前致謝！

查看完整描述

1 回答

狐的傳說(shuō)

TA貢獻(xiàn)1804條經(jīng)驗(yàn) 獲得超3個(gè)贊

這對(duì)我有用:)

private void setRetentionTime(String topicName, int retentionTime) {

ConfigResource resource = new ConfigResource(Type.TOPIC, topicName);

Collection<ConfigEntry> entries = new ArrayList<>();

entries.add(new ConfigEntry(TopicConfig.RETENTION_MS_CONFIG, String.valueOf(retentionTime)));

Config config = new Config(entries);

Map<ConfigResource, Config> configs = new HashMap<>();

configs.put(resource, config);

AdminClient client = kafkaConfig.createAdminClient();

client.alterConfigs(configs);

}

反對(duì) 回復(fù) 2023-10-12

拉風(fēng)的咖菲貓

TA貢獻(xiàn)1995條經(jīng)驗(yàn) 獲得超2個(gè)贊

我以前從 Java 知道你可以作為客戶端登錄。無(wú)法更改主題配置。

最近他們?cè)谛掳姹镜?Kafka 中引入了這一點(diǎn)，我認(rèn)為這是可能做到的。

https://kafka.apache.org/10/javadoc/org/apache/kafka/clients/admin/KafkaAdminClient.html#alterConfigs-java.util.Map-org.apache.kafka.clients.admin.AlterConfigsOptions-

我現(xiàn)在的答案聽起來(lái)有點(diǎn)模糊，但如果你想要完整的答案，你必須更具體。如果您有 Kafka 的確切版本、用于連接到 kafka 的庫(kù)等，我可以擴(kuò)展答案...

我認(rèn)為從應(yīng)用程序更改服務(wù)器端配置不是最好的主意。這是更多基礎(chǔ)設(shè)施的事情，不應(yīng)該在運(yùn)行應(yīng)用程序時(shí)在運(yùn)行時(shí)完成。

反對(duì) 回復(fù) 2023-10-12