|
@@ -92,7 +92,7 @@ export const formatTopicCreation = (form: TopicFormData): TopicCreation => {
|
|
retentionBytes,
|
|
retentionBytes,
|
|
retentionMs,
|
|
retentionMs,
|
|
maxMessageBytes,
|
|
maxMessageBytes,
|
|
- minInsyncReplicas,
|
|
|
|
|
|
+ minInSyncReplicas,
|
|
customParams,
|
|
customParams,
|
|
} = form;
|
|
} = form;
|
|
|
|
|
|
@@ -105,7 +105,7 @@ export const formatTopicCreation = (form: TopicFormData): TopicCreation => {
|
|
'retention.ms': retentionMs.toString(),
|
|
'retention.ms': retentionMs.toString(),
|
|
'retention.bytes': retentionBytes.toString(),
|
|
'retention.bytes': retentionBytes.toString(),
|
|
'max.message.bytes': maxMessageBytes.toString(),
|
|
'max.message.bytes': maxMessageBytes.toString(),
|
|
- 'min.insync.replicas': minInsyncReplicas.toString(),
|
|
|
|
|
|
+ 'min.insync.replicas': minInSyncReplicas.toString(),
|
|
...Object.values(customParams || {}).reduce(topicReducer, {}),
|
|
...Object.values(customParams || {}).reduce(topicReducer, {}),
|
|
},
|
|
},
|
|
};
|
|
};
|
|
@@ -153,7 +153,7 @@ const formatTopicUpdate = (form: TopicFormDataRaw): TopicUpdate => {
|
|
retentionBytes,
|
|
retentionBytes,
|
|
retentionMs,
|
|
retentionMs,
|
|
maxMessageBytes,
|
|
maxMessageBytes,
|
|
- minInsyncReplicas,
|
|
|
|
|
|
+ minInSyncReplicas,
|
|
customParams,
|
|
customParams,
|
|
} = form;
|
|
} = form;
|
|
|
|
|
|
@@ -163,7 +163,7 @@ const formatTopicUpdate = (form: TopicFormDataRaw): TopicUpdate => {
|
|
'retention.ms': retentionMs,
|
|
'retention.ms': retentionMs,
|
|
'retention.bytes': retentionBytes,
|
|
'retention.bytes': retentionBytes,
|
|
'max.message.bytes': maxMessageBytes,
|
|
'max.message.bytes': maxMessageBytes,
|
|
- 'min.insync.replicas': minInsyncReplicas,
|
|
|
|
|
|
+ 'min.insync.replicas': minInSyncReplicas,
|
|
...Object.values(customParams || {}).reduce(topicReducer, {}),
|
|
...Object.values(customParams || {}).reduce(topicReducer, {}),
|
|
},
|
|
},
|
|
};
|
|
};
|