rule-node-config.topic-pattern

@if (kafkaConfigForm.get('topicPattern').hasError('required')) { {{ 'rule-node-config.topic-pattern-required' | translate }} } rule-node-config.general-pattern-hint

rule-node-config.key-pattern

rule-node-config.general-pattern-hint

rule-node-config.key-pattern-hint

rule-node-config.bootstrap-servers

@if (kafkaConfigForm.get('bootstrapServers').hasError('required')) { {{ 'rule-node-config.bootstrap-servers-required' | translate }} }

rule-node-config.retries

@if (kafkaConfigForm.get('retries').hasError('min')) { {{ 'rule-node-config.min-retries-message' | translate }} }

rule-node-config.batch-size-bytes

@if (kafkaConfigForm.get('batchSize').hasError('min')) { {{ 'rule-node-config.min-batch-size-bytes-message' | translate }} }

rule-node-config.linger-ms

@if (kafkaConfigForm.get('linger').hasError('min')) { {{ 'rule-node-config.min-linger-ms-message' | translate }} }

rule-node-config.buffer-memory-bytes

@if (kafkaConfigForm.get('bufferMemory').hasError('min')) { {{ 'rule-node-config.min-buffer-memory-bytes-message' | translate }} }

rule-node-config.acks

@for (ackValue of ackValues; track ackValue) { {{ ackValue }} }

rule-node-config.other-properties

{{ 'rule-node-config.add-metadata-key-values-as-kafka-headers' | translate }}

rule-node-config.add-metadata-key-values-as-kafka-headers-hint

@if (kafkaConfigForm.get('addMetadataKeyValuesAsKafkaHeaders').value) {

rule-node-config.charset-encoding

@for (charset of ToByteStandartCharsetTypesValues; track charset) { {{ ToByteStandartCharsetTypeTranslationMap.get(charset) | translate }} }

}