-
Processors
- AttributeRollingWindow
- AttributesToCSV
- AttributesToJSON
- CalculateRecordStats
- CaptureChangeMySQL
- CompressContent
- ConnectWebSocket
- ConsumeAMQP
- ConsumeAzureEventHub
- ConsumeBoxEnterpriseEvents
- ConsumeBoxEvents
- ConsumeElasticsearch
- ConsumeGCPubSub
- ConsumeIMAP
- ConsumeJMS
- ConsumeKafka
- ConsumeKinesis
- ConsumeKinesisStream
- ConsumeMQTT
- ConsumePOP3
- ConsumeSlack
- ConsumeTwitter
- ConsumeWindowsEventLog
- ControlRate
- ConvertCharacterSet
- ConvertRecord
- CopyAzureBlobStorage_v12
- CopyS3Object
- CountText
- CreateBoxFileMetadataInstance
- CreateBoxMetadataTemplate
- CryptographicHashContent
- DebugFlow
- DecryptContentAge
- DecryptContentPGP
- DeduplicateRecord
- DeleteAzureBlobStorage_v12
- DeleteAzureDataLakeStorage
- DeleteBoxFileMetadataInstance
- DeleteByQueryElasticsearch
- DeleteDynamoDB
- DeleteFile
- DeleteGCSObject
- DeleteGridFS
- DeleteMongo
- DeleteS3Object
- DeleteSFTP
- DeleteSQS
- DetectDuplicate
- DistributeLoad
- DuplicateFlowFile
- EncodeContent
- EncryptContentAge
- EncryptContentPGP
- EnforceOrder
- EvaluateJsonPath
- EvaluateXPath
- EvaluateXQuery
- ExecuteGroovyScript
- ExecuteProcess
- ExecuteScript
- ExecuteSQL
- ExecuteSQLRecord
- ExecuteStreamCommand
- ExtractAvroMetadata
- ExtractEmailAttachments
- ExtractEmailHeaders
- ExtractGrok
- ExtractHL7Attributes
- ExtractRecordSchema
- ExtractStructuredBoxFileMetadata
- ExtractText
- FetchAzureBlobStorage_v12
- FetchAzureDataLakeStorage
- FetchBoxFile
- FetchBoxFileInfo
- FetchBoxFileMetadataInstance
- FetchBoxFileRepresentation
- FetchDistributedMapCache
- FetchDropbox
- FetchFile
- FetchFTP
- FetchGCSObject
- FetchGoogleDrive
- FetchGridFS
- FetchS3Object
- FetchSFTP
- FetchSmb
- FilterAttribute
- FlattenJson
- ForkEnrichment
- ForkRecord
- GenerateFlowFile
- GenerateRecord
- GenerateTableFetch
- GeoEnrichIP
- GeoEnrichIPRecord
- GeohashRecord
- GetAsanaObject
- GetAwsPollyJobStatus
- GetAwsTextractJobStatus
- GetAwsTranscribeJobStatus
- GetAwsTranslateJobStatus
- GetAzureEventHub
- GetAzureQueueStorage_v12
- GetBoxFileCollaborators
- GetBoxGroupMembers
- GetDynamoDB
- GetElasticsearch
- GetFile
- GetFileResource
- GetFTP
- GetGcpVisionAnnotateFilesOperationStatus
- GetGcpVisionAnnotateImagesOperationStatus
- GetHubSpot
- GetMongo
- GetMongoRecord
- GetS3ObjectMetadata
- GetS3ObjectTags
- GetSFTP
- GetShopify
- GetSmbFile
- GetSNMP
- GetSplunk
- GetSQS
- GetWorkdayReport
- GetZendesk
- HandleHttpRequest
- HandleHttpResponse
- IdentifyMimeType
- InvokeHTTP
- InvokeScriptedProcessor
- ISPEnrichIP
- JoinEnrichment
- JoltTransformJSON
- JoltTransformRecord
- JSLTTransformJSON
- JsonQueryElasticsearch
- ListAzureBlobStorage_v12
- ListAzureDataLakeStorage
- ListBoxFile
- ListBoxFileInfo
- ListBoxFileMetadataInstances
- ListBoxFileMetadataTemplates
- ListDatabaseTables
- ListDropbox
- ListenFTP
- ListenHTTP
- ListenOTLP
- ListenSlack
- ListenSyslog
- ListenTCP
- ListenTrapSNMP
- ListenUDP
- ListenUDPRecord
- ListenWebSocket
- ListFile
- ListFTP
- ListGCSBucket
- ListGoogleDrive
- ListS3
- ListSFTP
- ListSmb
- LogAttribute
- LogMessage
- LookupAttribute
- LookupRecord
- MergeContent
- MergeRecord
- ModifyBytes
- ModifyCompression
- MonitorActivity
- MoveAzureDataLakeStorage
- Notify
- PackageFlowFile
- PaginatedJsonQueryElasticsearch
- ParseEvtx
- ParseNetflowv5
- ParseSyslog
- ParseSyslog5424
- PartitionRecord
- PublishAMQP
- PublishGCPubSub
- PublishJMS
- PublishKafka
- PublishMQTT
- PublishSlack
- PutAzureBlobStorage_v12
- PutAzureCosmosDBRecord
- PutAzureDataExplorer
- PutAzureDataLakeStorage
- PutAzureEventHub
- PutAzureQueueStorage_v12
- PutBigQuery
- PutBoxFile
- PutCloudWatchMetric
- PutDatabaseRecord
- PutDistributedMapCache
- PutDropbox
- PutDynamoDB
- PutDynamoDBRecord
- PutElasticsearchJson
- PutElasticsearchRecord
- PutEmail
- PutFile
- PutFTP
- PutGCSObject
- PutGoogleDrive
- PutGridFS
- PutIcebergRecord
- PutKinesisFirehose
- PutKinesisStream
- PutLambda
- PutMongo
- PutMongoBulkOperations
- PutMongoRecord
- PutRecord
- PutRedisHashRecord
- PutS3Object
- PutSalesforceObject
- PutSFTP
- PutSmbFile
- PutSNS
- PutSplunk
- PutSplunkHTTP
- PutSQL
- PutSQS
- PutSyslog
- PutTCP
- PutUDP
- PutWebSocket
- PutZendeskTicket
- QueryAirtableTable
- QueryAzureDataExplorer
- QueryDatabaseTable
- QueryDatabaseTableRecord
- QueryRecord
- QuerySalesforceObject
- QuerySplunkIndexingStatus
- RemoveRecordField
- RenameRecordField
- ReplaceText
- ReplaceTextWithMapping
- RetryFlowFile
- RouteHL7
- RouteOnAttribute
- RouteOnContent
- RouteText
- RunMongoAggregation
- SampleRecord
- ScanAttribute
- ScanContent
- ScriptedFilterRecord
- ScriptedPartitionRecord
- ScriptedTransformRecord
- ScriptedValidateRecord
- SearchElasticsearch
- SegmentContent
- SendTrapSNMP
- SetSNMP
- SignContentPGP
- SplitAvro
- SplitContent
- SplitExcel
- SplitJson
- SplitPCAP
- SplitRecord
- SplitText
- SplitXml
- StartAwsPollyJob
- StartAwsTextractJob
- StartAwsTranscribeJob
- StartAwsTranslateJob
- StartGcpVisionAnnotateFilesOperation
- StartGcpVisionAnnotateImagesOperation
- TagS3Object
- TailFile
- TransformXml
- UnpackContent
- UpdateAttribute
- UpdateBoxFileMetadataInstance
- UpdateByQueryElasticsearch
- UpdateCounter
- UpdateDatabaseTable
- UpdateRecord
- ValidateCsv
- ValidateJson
- ValidateRecord
- ValidateXml
- VerifyContentMAC
- VerifyContentPGP
- Wait
-
Controller Services
- ADLSCredentialsControllerService
- ADLSCredentialsControllerServiceLookup
- ADLSIcebergFileIOProvider
- AmazonGlueEncodedSchemaReferenceReader
- AmazonGlueSchemaRegistry
- AmazonMSKConnectionService
- ApicurioSchemaRegistry
- AvroReader
- AvroRecordSetWriter
- AvroSchemaRegistry
- AWSCredentialsProviderControllerService
- AwsRdsIamDatabasePasswordProvider
- AzureBlobStorageFileResourceService
- AzureCosmosDBClientService
- AzureDataLakeStorageFileResourceService
- AzureEventHubRecordSink
- AzureStorageCredentialsControllerService_v12
- AzureStorageCredentialsControllerServiceLookup_v12
- CEFReader
- ConfluentEncodedSchemaReferenceReader
- ConfluentEncodedSchemaReferenceWriter
- ConfluentProtobufMessageNameResolver
- ConfluentSchemaRegistry
- CSVReader
- CSVRecordLookupService
- CSVRecordSetWriter
- DatabaseRecordLookupService
- DatabaseRecordSink
- DatabaseTableSchemaRegistry
- DBCPConnectionPool
- DBCPConnectionPoolLookup
- DeveloperBoxClientService
- DistributedMapCacheLookupService
- ElasticSearchClientServiceImpl
- ElasticSearchLookupService
- ElasticSearchStringLookupService
- EmailRecordSink
- EmbeddedHazelcastCacheManager
- ExcelReader
- ExternalHazelcastCacheManager
- FreeFormTextRecordSetWriter
- GCPCredentialsControllerService
- GCSFileResourceService
- GrokReader
- HazelcastMapCacheClient
- HikariCPConnectionPool
- HttpRecordSink
- IPLookupService
- JettyWebSocketClient
- JettyWebSocketServer
- JMSConnectionFactoryProvider
- JndiJmsConnectionFactoryProvider
- JsonConfigBasedBoxClientService
- JsonPathReader
- JsonRecordSetWriter
- JsonTreeReader
- JWTBearerOAuth2AccessTokenProvider
- Kafka3ConnectionService
- KerberosKeytabUserService
- KerberosPasswordUserService
- KerberosTicketCacheUserService
- LoggingRecordSink
- MapCacheClientService
- MapCacheServer
- MongoDBControllerService
- MongoDBLookupService
- ParquetIcebergWriter
- PEMEncodedSSLContextProvider
- PropertiesFileLookupService
- ProtobufReader
- ReaderLookup
- RecordSetWriterLookup
- RecordSinkServiceLookup
- RedisConnectionPoolService
- RedisDistributedMapCacheClientService
- RESTIcebergCatalog
- RestLookupService
- S3FileResourceService
- S3IcebergFileIOProvider
- ScriptedLookupService
- ScriptedReader
- ScriptedRecordSetWriter
- ScriptedRecordSink
- SetCacheClientService
- SetCacheServer
- SimpleCsvFileLookupService
- SimpleDatabaseLookupService
- SimpleKeyValueLookupService
- SimpleRedisDistributedMapCacheClientService
- SimpleScriptedLookupService
- SiteToSiteReportingRecordSink
- SlackRecordSink
- SmbjClientProviderService
- StandardAsanaClientProviderService
- StandardAzureCredentialsControllerService
- StandardDatabaseDialectService
- StandardDropboxCredentialService
- StandardFileResourceService
- StandardHashiCorpVaultClientService
- StandardHttpContextMap
- StandardJsonSchemaRegistry
- StandardKustoIngestService
- StandardKustoQueryService
- StandardOauth2AccessTokenProvider
- StandardPGPPrivateKeyService
- StandardPGPPublicKeyService
- StandardPrivateKeyService
- StandardProtobufReader
- StandardProxyConfigurationService
- StandardRestrictedSSLContextService
- StandardS3EncryptionService
- StandardSSLContextService
- StandardWebClientServiceProvider
- Syslog5424Reader
- SyslogReader
- UDPEventRecordSink
- VolatileSchemaCache
- WindowsEventLogReader
- XMLFileLookupService
- XMLReader
- XMLRecordSetWriter
- YamlTreeReader
- ZendeskRecordSink
AmazonMSKConnectionService 2.7.0
- Bundle
- org.apache.nifi | nifi-kafka-service-aws-nar
- Description
- Provides and manages connections to AWS MSK Kafka Brokers for producer or consumer operations.
- Tags
- AWS, MSK, kafka, streaming
- Input Requirement
- Supports Sensitive Dynamic Properties
- false
Properties
-
Acknowledgment Wait Time
After sending a message to Kafka, this indicates the amount of time that the service will wait for a response from Kafka. If Kafka does not acknowledge the message within this time period, the service will throw an exception.
- Display Name
- Acknowledgment Wait Time
- Description
- After sending a message to Kafka, this indicates the amount of time that the service will wait for a response from Kafka. If Kafka does not acknowledge the message within this time period, the service will throw an exception.
- API Name
- ack.wait.time
- Default Value
- 5 sec
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
AWS Assume Role ARN
The AWS Role ARN for cross-account access when using AWS MSK IAM. Used with Assume Role Session Name.
- Display Name
- AWS Assume Role ARN
- Description
- The AWS Role ARN for cross-account access when using AWS MSK IAM. Used with Assume Role Session Name.
- API Name
- AWS Assume Role ARN
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
- Dependencies
-
- AWS Role Source is set to any of [SPECIFIED_ROLE, WEB_IDENTITY_TOKEN]
-
AWS Assume Role Session Name
The AWS Role Session Name for cross-account access. Used in conjunction with Assume Role ARN.
- Display Name
- AWS Assume Role Session Name
- Description
- The AWS Role Session Name for cross-account access. Used in conjunction with Assume Role ARN.
- API Name
- AWS Assume Role Session Name
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
- Dependencies
-
- AWS Role Source is set to any of [SPECIFIED_ROLE, WEB_IDENTITY_TOKEN]
-
AWS Role Source
Select how AWS credentials are sourced for AWS MSK IAM: Default Profile searches standard locations, Specified Profile selects a named profile, or Specified Role configures a Role ARN and Session Name.
- Display Name
- AWS Role Source
- Description
- Select how AWS credentials are sourced for AWS MSK IAM: Default Profile searches standard locations, Specified Profile selects a named profile, or Specified Role configures a Role ARN and Session Name.
- API Name
- AWS Role Source
- Default Value
- DEFAULT_PROFILE
- Allowable Values
-
- Default Profile
- Specified Profile
- Specified Role
- Web Identity Provider
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
- Dependencies
-
- SASL Mechanism is set to any of [AWS_MSK_IAM]
-
AWS Web Identity Session Time
Session time for AWS STS AssumeRoleWithWebIdentity (between 900 seconds and 3600 seconds).
- Display Name
- AWS Web Identity Session Time
- Description
- Session time for AWS STS AssumeRoleWithWebIdentity (between 900 seconds and 3600 seconds).
- API Name
- AWS Web Identity Session Time
- Default Value
- 3600 sec
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
- Dependencies
-
- AWS Role Source is set to any of [WEB_IDENTITY_TOKEN]
-
AWS Web Identity SSL Context Provider
SSL Context Service used when communicating with AWS STS for Web Identity federation.
- Display Name
- AWS Web Identity SSL Context Provider
- Description
- SSL Context Service used when communicating with AWS STS for Web Identity federation.
- API Name
- AWS Web Identity SSL Context Provider
- Service Interface
- org.apache.nifi.ssl.SSLContextProvider
- Service Implementations
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- false
- Dependencies
-
- AWS Role Source is set to any of [WEB_IDENTITY_TOKEN]
-
AWS Web Identity STS Endpoint
Optional endpoint override for the AWS Security Token Service.
- Display Name
- AWS Web Identity STS Endpoint
- Description
- Optional endpoint override for the AWS Security Token Service.
- API Name
- AWS Web Identity STS Endpoint
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- false
- Dependencies
-
- AWS Role Source is set to any of [WEB_IDENTITY_TOKEN]
-
AWS Web Identity STS Region
Region identifier used for the AWS Security Token Service when exchanging Web Identity tokens.
- Display Name
- AWS Web Identity STS Region
- Description
- Region identifier used for the AWS Security Token Service when exchanging Web Identity tokens.
- API Name
- AWS Web Identity STS Region
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- false
- Dependencies
-
- AWS Role Source is set to any of [WEB_IDENTITY_TOKEN]
-
AWS Web Identity Token Provider
Controller Service providing tokens with OAuth2 OpenID Connect for AWS Web Identity federation.
- Display Name
- AWS Web Identity Token Provider
- Description
- Controller Service providing tokens with OAuth2 OpenID Connect for AWS Web Identity federation.
- API Name
- AWS Web Identity Token Provider
- Service Interface
- org.apache.nifi.oauth2.OAuth2AccessTokenProvider
- Service Implementations
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
- Dependencies
-
- AWS Role Source is set to any of [WEB_IDENTITY_TOKEN]
-
AWS Profile Name
The Amazon Web Services Profile to select when multiple profiles are available.
- Display Name
- AWS Profile Name
- Description
- The Amazon Web Services Profile to select when multiple profiles are available.
- API Name
- aws.profile.name
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
- Dependencies
-
- AWS Role Source is set to any of [SPECIFIED_PROFILE]
-
Bootstrap Servers
Comma-separated list of Kafka Bootstrap Servers in the format host:port. Corresponds to Kafka bootstrap.servers property
- Display Name
- Bootstrap Servers
- Description
- Comma-separated list of Kafka Bootstrap Servers in the format host:port. Corresponds to Kafka bootstrap.servers property
- API Name
- bootstrap.servers
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
Client Timeout
Default timeout for Kafka client operations. Mapped to Kafka default.api.timeout.ms. The Kafka request.timeout.ms property is derived from half of the configured timeout
- Display Name
- Client Timeout
- Description
- Default timeout for Kafka client operations. Mapped to Kafka default.api.timeout.ms. The Kafka request.timeout.ms property is derived from half of the configured timeout
- API Name
- default.api.timeout.ms
- Default Value
- 60 sec
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
Transaction Isolation Level
Specifies how the service should handle transaction isolation levels when communicating with Kafka. The uncommited option means that messages will be received as soon as they are written to Kafka but will be pulled, even if the producer cancels the transactions. The committed option configures the service to not receive any messages for which the producer's transaction was canceled, but this can result in some latency since the consumer must wait for the producer to finish its entire transaction instead of pulling as the messages become available. Corresponds to Kafka isolation.level property.
- Display Name
- Transaction Isolation Level
- Description
- Specifies how the service should handle transaction isolation levels when communicating with Kafka. The uncommited option means that messages will be received as soon as they are written to Kafka but will be pulled, even if the producer cancels the transactions. The committed option configures the service to not receive any messages for which the producer's transaction was canceled, but this can result in some latency since the consumer must wait for the producer to finish its entire transaction instead of pulling as the messages become available. Corresponds to Kafka isolation.level property.
- API Name
- isolation.level
- Default Value
- read_committed
- Allowable Values
-
- Read Committed
- Read Uncommitted
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
Kerberos User Service
Service supporting user authentication with Kerberos
- Display Name
- Kerberos User Service
- Description
- Service supporting user authentication with Kerberos
- API Name
- kerberos-user-service
- Service Interface
- org.apache.nifi.kerberos.SelfContainedKerberosUserService
- Service Implementations
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
- Dependencies
-
- SASL Mechanism is set to any of [GSSAPI]
-
Max Metadata Wait Time
The amount of time publisher will wait to obtain metadata or wait for the buffer to flush during the 'send' call before failing the entire 'send' call. Corresponds to Kafka max.block.ms property
- Display Name
- Max Metadata Wait Time
- Description
- The amount of time publisher will wait to obtain metadata or wait for the buffer to flush during the 'send' call before failing the entire 'send' call. Corresponds to Kafka max.block.ms property
- API Name
- max.block.ms
- Default Value
- 5 sec
- Expression Language Scope
- Environment variables defined at JVM level and system properties
- Sensitive
- false
- Required
- true
-
Max Poll Records
Maximum number of records Kafka should return in a single poll.
- Display Name
- Max Poll Records
- Description
- Maximum number of records Kafka should return in a single poll.
- API Name
- max.poll.records
- Default Value
- 10000
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
OAuth2 Access Token Provider Service
Service providing OAuth2 Access Tokens for authentication
- Display Name
- OAuth2 Access Token Provider Service
- Description
- Service providing OAuth2 Access Tokens for authentication
- API Name
- oauth2-access-token-provider-service
- Service Interface
- org.apache.nifi.oauth2.OAuth2AccessTokenProvider
- Service Implementations
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
- Dependencies
-
- SASL Mechanism is set to any of [OAUTHBEARER]
-
Kerberos Service Name
The service name that matches the primary name of the Kafka server configured in the broker JAAS configuration
- Display Name
- Kerberos Service Name
- Description
- The service name that matches the primary name of the Kafka server configured in the broker JAAS configuration
- API Name
- sasl.kerberos.service.name
- Expression Language Scope
- Environment variables defined at JVM level and system properties
- Sensitive
- false
- Required
- true
- Dependencies
-
- SASL Mechanism is set to any of [GSSAPI]
-
SASL Mechanism
SASL mechanism used for authentication. Corresponds to Kafka Client sasl.mechanism property
- Display Name
- SASL Mechanism
- Description
- SASL mechanism used for authentication. Corresponds to Kafka Client sasl.mechanism property
- API Name
- sasl.mechanism
- Default Value
- AWS_MSK_IAM
- Allowable Values
-
- AWS_MSK_IAM
- SCRAM-SHA-512
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
- Dependencies
-
- Security Protocol is set to any of [SASL_PLAINTEXT, SASL_SSL]
-
SASL Password
Password provided with configured username when using PLAIN or SCRAM SASL Mechanisms
- Display Name
- SASL Password
- Description
- Password provided with configured username when using PLAIN or SCRAM SASL Mechanisms
- API Name
- sasl.password
- Expression Language Scope
- Environment variables defined at JVM level and system properties
- Sensitive
- true
- Required
- true
- Dependencies
-
- SASL Mechanism is set to any of [PLAIN, SCRAM-SHA-256, SCRAM-SHA-512]
-
SASL Username
Username provided with configured password when using PLAIN or SCRAM SASL Mechanisms
- Display Name
- SASL Username
- Description
- Username provided with configured password when using PLAIN or SCRAM SASL Mechanisms
- API Name
- sasl.username
- Expression Language Scope
- Environment variables defined at JVM level and system properties
- Sensitive
- false
- Required
- true
- Dependencies
-
- SASL Mechanism is set to any of [PLAIN, SCRAM-SHA-256, SCRAM-SHA-512]
-
Security Protocol
Security protocol used to communicate with brokers. Corresponds to Kafka Client security.protocol property
- Display Name
- Security Protocol
- Description
- Security protocol used to communicate with brokers. Corresponds to Kafka Client security.protocol property
- API Name
- security.protocol
- Default Value
- PLAINTEXT
- Allowable Values
-
- PLAINTEXT
- SSL
- SASL_PLAINTEXT
- SASL_SSL
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
SSL Context Service
Service supporting SSL communication with Kafka brokers
- Display Name
- SSL Context Service
- Description
- Service supporting SSL communication with Kafka brokers
- API Name
- SSL Context Service
- Service Interface
- org.apache.nifi.ssl.SSLContextService
- Service Implementations
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- false
- Dependencies
-
- Security Protocol is set to any of [SASL_SSL, SSL]
Dynamic Properties
-
The name of a Kafka configuration property or a SASL extension property.
Kafka configuration properties will be added on the Kafka configuration after loading any provided configuration properties. In the event a dynamic property represents a property that was already set, its value will be ignored and WARN message logged. For the list of available Kafka properties please refer to: http://kafka.apache.org/documentation.html#configuration. SASL extension properties can be specified in sasl_extension_propertyName format (e.g. sasl_extension_logicalCluster).
- Name
- The name of a Kafka configuration property or a SASL extension property.
- Description
- Kafka configuration properties will be added on the Kafka configuration after loading any provided configuration properties. In the event a dynamic property represents a property that was already set, its value will be ignored and WARN message logged. For the list of available Kafka properties please refer to: http://kafka.apache.org/documentation.html#configuration. SASL extension properties can be specified in sasl_extension_propertyName format (e.g. sasl_extension_logicalCluster).
- Value
- The value of the given property.
- Expression Language Scope
- ENVIRONMENT