TopicMetadataRefreshFastIntervalMs Property
General info
Label |
Topic Metadata Refresh Fast Interval |
Description |
When a topic loses its leader a new metadata request will be enqueued with this initial interval, exponentially increasing until the topic metadata has been refreshed. This is used to recover quickly from transitioning leader brokers. |
Data type |
Int32 |
Default value |
250 |
Min value |
1 |
Max value |
60000 |
Type |
Regular |
Code |
6613 |
Symbolic name |
MODEL_PROP_TOPICMETADATAREFRESHFASTINTERVALMS |
Lua access code |
syslib.model.properties.TopicMetadataRefreshFastIntervalMs |
Available since |
1.54 |
- Parent properties
-
AdvancedConfiguration | KafkaConsumerProperties | KafkaProducerProperties
Attributes
| Name | Tooltip |
|---|---|
| PROP_CONFIGURABLE | The property is configurable and can be changed with DataStudio and the various inmation APIs. |
| PROP_VISIBLE | The property is visible in DataStudio and can be read by the inmation APIs. |
| PROP_HAS_DEFAULT | The property has a default value as standard. |
| PROP_UNIT | The property has an engineering unit. |
| PROP_HAS_LOLIMIT | The property has a low limit. |
| PROP_HAS_HILIMIT | The property has a high limit. |
Examples
Read from or write to the TopicMetadataRefreshFastIntervalMs property.
-- Read from the TopicMetadataRefreshFastIntervalMs
syslib.getvalue("<OBJECT FULL PATH>.KafkaProducerProperties.TopicMetadataRefreshFastIntervalMs")
-- Write to the TopicMetadataRefreshFastIntervalMs
syslib.setvalue("<OBJECT FULL PATH>.KafkaProducerProperties.TopicMetadataRefreshFastIntervalMs", 250)TcpConfig tcpcfg = new TcpConfig() { HostNameOrIp = "localhost", Port = 6512 };
SecurityCredentials sc = new SecurityCredentials() { ProfileName = "<username>", Password = "<password>" };
StatelessInterface sli = new StatelessInterface(tcpcfg);
// Read from the TopicMetadataRefreshFastIntervalMs
Result result = sli.ReadValue(sc, new ReadItem("<OBJECT FULL PATH>.KafkaProducerProperties.TopicMetadataRefreshFastIntervalMs"));
// Write to the TopicMetadataRefreshFastIntervalMs
Result result = sli.WriteValue(sc, new WriteItem(250, "<OBJECT FULL PATH>.KafkaProducerProperties.TopicMetadataRefreshFastIntervalMs"));