ObservabilityPipelineKafkaDestination |
ObservabilityPipelineKafkaDestination.addInputsItem(String inputsItem) |
ObservabilityPipelineKafkaDestination |
ObservabilityPipelineKafkaDestination.addLibrdkafkaOptionsItem(ObservabilityPipelineKafkaLibrdkafkaOption librdkafkaOptionsItem) |
ObservabilityPipelineKafkaDestination |
ObservabilityPipelineKafkaDestination.bootstrapServersKey(String bootstrapServersKey) |
ObservabilityPipelineKafkaDestination |
ObservabilityPipelineKafkaDestination.buffer(ObservabilityPipelineBufferOptions buffer) |
ObservabilityPipelineKafkaDestination |
ObservabilityPipelineKafkaDestination.compression(ObservabilityPipelineKafkaDestinationCompression compression) |
ObservabilityPipelineKafkaDestination |
ObservabilityPipelineKafkaDestination.encoding(ObservabilityPipelineKafkaDestinationEncoding encoding) |
ObservabilityPipelineKafkaDestination |
ObservabilityPipelineConfigDestinationItem.getObservabilityPipelineKafkaDestination()
Get the actual instance of `ObservabilityPipelineKafkaDestination`.
|
ObservabilityPipelineKafkaDestination |
ObservabilityPipelineKafkaDestination.headersKey(String headersKey) |
ObservabilityPipelineKafkaDestination |
ObservabilityPipelineKafkaDestination.id(String id) |
ObservabilityPipelineKafkaDestination |
ObservabilityPipelineKafkaDestination.inputs(List<String> inputs) |
ObservabilityPipelineKafkaDestination |
ObservabilityPipelineKafkaDestination.keyField(String keyField) |
ObservabilityPipelineKafkaDestination |
ObservabilityPipelineKafkaDestination.librdkafkaOptions(List<ObservabilityPipelineKafkaLibrdkafkaOption> librdkafkaOptions) |
ObservabilityPipelineKafkaDestination |
ObservabilityPipelineKafkaDestination.messageTimeoutMs(Long messageTimeoutMs) |
ObservabilityPipelineKafkaDestination |
ObservabilityPipelineKafkaDestination.putAdditionalProperty(String key,
Object value)
Set the additional (undeclared) property with the specified name and value.
|
ObservabilityPipelineKafkaDestination |
ObservabilityPipelineKafkaDestination.rateLimitDurationSecs(Long rateLimitDurationSecs) |
ObservabilityPipelineKafkaDestination |
ObservabilityPipelineKafkaDestination.rateLimitNum(Long rateLimitNum) |
ObservabilityPipelineKafkaDestination |
ObservabilityPipelineKafkaDestination.sasl(ObservabilityPipelineKafkaSasl sasl) |
ObservabilityPipelineKafkaDestination |
ObservabilityPipelineKafkaDestination.socketTimeoutMs(Long socketTimeoutMs) |
ObservabilityPipelineKafkaDestination |
ObservabilityPipelineKafkaDestination.tls(ObservabilityPipelineTls tls) |
ObservabilityPipelineKafkaDestination |
ObservabilityPipelineKafkaDestination.topic(String topic) |
ObservabilityPipelineKafkaDestination |
ObservabilityPipelineKafkaDestination.type(ObservabilityPipelineKafkaDestinationType type) |