ObservabilityPipelineKafkaSource |
ObservabilityPipelineKafkaSource.addLibrdkafkaOptionsItem(ObservabilityPipelineKafkaLibrdkafkaOption librdkafkaOptionsItem) |
ObservabilityPipelineKafkaSource |
ObservabilityPipelineKafkaSource.addTopicsItem(String topicsItem) |
ObservabilityPipelineKafkaSource |
ObservabilityPipelineKafkaSource.bootstrapServersKey(String bootstrapServersKey) |
ObservabilityPipelineKafkaSource |
ObservabilityPipelineConfigSourceItem.getObservabilityPipelineKafkaSource()
Get the actual instance of `ObservabilityPipelineKafkaSource`.
|
ObservabilityPipelineKafkaSource |
ObservabilityPipelineKafkaSource.groupId(String groupId) |
ObservabilityPipelineKafkaSource |
ObservabilityPipelineKafkaSource.id(String id) |
ObservabilityPipelineKafkaSource |
ObservabilityPipelineKafkaSource.librdkafkaOptions(List<ObservabilityPipelineKafkaLibrdkafkaOption> librdkafkaOptions) |
ObservabilityPipelineKafkaSource |
ObservabilityPipelineKafkaSource.putAdditionalProperty(String key,
Object value)
Set the additional (undeclared) property with the specified name and value.
|
ObservabilityPipelineKafkaSource |
ObservabilityPipelineKafkaSource.sasl(ObservabilityPipelineKafkaSasl sasl) |
ObservabilityPipelineKafkaSource |
ObservabilityPipelineKafkaSource.tls(ObservabilityPipelineTls tls) |
ObservabilityPipelineKafkaSource |
ObservabilityPipelineKafkaSource.topics(List<String> topics) |
ObservabilityPipelineKafkaSource |
ObservabilityPipelineKafkaSource.type(ObservabilityPipelineKafkaSourceType type) |