com.celonis.kafka.connect.transform.RecordTransformerTest ‑ With Chunking disabled, heterogeneous arrays prevent flattening
com.celonis.kafka.connect.transform.RecordTransformerTest ‑ With Chunking disabled, heterogeneous arrays prevents flattening, even with discardCollection enabled

com.celonis.kafka.connect.ems.config.AuthorizationTests ‑ return an error if connect.ems.authorization.key is empty
com.celonis.kafka.connect.ems.config.AuthorizationTests ‑ return an error if connect.ems.authorization.key is missing
com.celonis.kafka.connect.ems.config.AuthorizationTests ‑ return an error if connect.ems.authorization.key is not a string
com.celonis.kafka.connect.ems.config.AuthorizationTests ‑ return an error if connect.ems.authorization.key is not matching the expected format
com.celonis.kafka.connect.ems.config.AuthorizationTests ‑ return the value provided by connect.ems.authorization.key setting
com.celonis.kafka.connect.ems.config.CommitPolicyConfigTests ‑ return an error if commit policy connect.ems.commit.records is missing
com.celonis.kafka.connect.ems.config.CommitPolicyConfigTests ‑ return an error if commit policy connect.ems.commit.size.bytes is missing
com.celonis.kafka.connect.ems.config.CommitPolicyConfigTests ‑ return an error if commit policy keys are missing
com.celonis.kafka.connect.ems.config.CommitPolicyConfigTests ‑ return an error if connect.ems.commit.interval.ms is less than 1000
com.celonis.kafka.connect.ems.config.CommitPolicyConfigTests ‑ return an error if connect.ems.commit.interval.ms is missing
com.celonis.kafka.connect.ems.config.CommitPolicyConfigTests ‑ return an error if connect.ems.commit.size.bytes is less than 100KB
com.celonis.kafka.connect.ems.config.CommitPolicyConfigTests ‑ return the commit policy
com.celonis.kafka.connect.ems.config.EmsSinkConfigTest ‑ config properties not defined in config def are ignored
com.celonis.kafka.connect.ems.config.EmsSinkConfigTest ‑ handles AppKey with quotation
com.celonis.kafka.connect.ems.config.EmsSinkConfigTest ‑ hardcodes the working directory and forces Parquet file deletion if in memory file system is enabled
com.celonis.kafka.connect.ems.config.EmsSinkConfigTest ‑ parse PreConversionConfig
com.celonis.kafka.connect.ems.config.EmsSinkConfigTest ‑ parse the configuration from properties
com.celonis.kafka.connect.ems.config.EmsSinkConfigTest ‑ parse the configuration from properties without defaults
com.celonis.kafka.connect.ems.config.EmsSinkConfigTest ‑ returns THROW if connect.ems.error.policy is missing
com.celonis.kafka.connect.ems.config.EmsSinkConfigTest ‑ returns an default * obfuscation when connect.ems.obfuscation.method is missing and connect.ems.obfuscation.fields is present
com.celonis.kafka.connect.ems.config.EmsSinkConfigTest ‑ returns an error if AUTHORIZATION_KEY is missing
com.celonis.kafka.connect.ems.config.EmsSinkConfigTest ‑ returns an error if connect.ems.commit.interval.ms is missing
com.celonis.kafka.connect.ems.config.EmsSinkConfigTest ‑ returns an error if connect.ems.commit.records is missing
com.celonis.kafka.connect.ems.config.EmsSinkConfigTest ‑ returns an error if connect.ems.commit.size.bytes is missing
com.celonis.kafka.connect.ems.config.EmsSinkConfigTest ‑ returns an error if connect.ems.endpoint is missing
com.celonis.kafka.connect.ems.config.EmsSinkConfigTest ‑ returns an error if connect.ems.target.table is missing
com.celonis.kafka.connect.ems.config.EmsSinkConfigTest ‑ returns an error if connect.ems.tmp.dir is missing
com.celonis.kafka.connect.ems.config.EmsSinkConfigTest ‑ returns default if connect.ems.connection.id is missing
com.celonis.kafka.connect.ems.config.EmsSinkConfigTest ‑ returns default if connect.ems.data.fallback.varchar.length is missing
com.celonis.kafka.connect.ems.config.EmsSinkConfigTest ‑ returns default if connect.ems.data.primary.key is missing
com.celonis.kafka.connect.ems.config.EmsSinkConfigTest ‑ returns default if connect.ems.debug.keep.parquet.files is missing
com.celonis.kafka.connect.ems.config.EmsSinkConfigTest ‑ returns default if connect.ems.parquet.row.group.size.bytes is missing
com.celonis.kafka.connect.ems.config.EmsSinkConfigTest ‑ uses the order field name specified
com.celonis.kafka.connect.ems.config.EndpointTests ‑ return an error if connect.ems.endpoint is missing
com.celonis.kafka.connect.ems.config.EndpointTests ‑ return an error if connect.ems.endpoint is not a valid URL
com.celonis.kafka.connect.ems.config.EndpointTests ‑ return an error if connect.ems.endpoint is not using HTTPS protocol
com.celonis.kafka.connect.ems.config.EndpointTests ‑ return the EMS endpoint
com.celonis.kafka.connect.ems.config.ErrorPolicyTests ‑ handle an error according to the configured error policy
com.celonis.kafka.connect.ems.config.ErrorPolicyTests ‑ return an error if connect.ems.error.policy is empty
com.celonis.kafka.connect.ems.config.ErrorPolicyTests ‑ return an error if connect.ems.error.policy is invalid
com.celonis.kafka.connect.ems.config.ErrorPolicyTests ‑ return an error if connect.ems.error.policy is missing
com.celonis.kafka.connect.ems.config.ErrorPolicyTests ‑ return an error if connect.ems.error.policy is not a string
com.celonis.kafka.connect.ems.config.ErrorPolicyTests ‑ return the target table provided with connect.ems.error.policy
com.celonis.kafka.connect.ems.config.FallbackVarCharLengthTests ‑ return an error if the value is smaller than 1
com.celonis.kafka.connect.ems.config.FallbackVarCharLengthTests ‑ return default if the key is missing
com.celonis.kafka.connect.ems.config.FallbackVarCharLengthTests ‑ return the given value
com.celonis.kafka.connect.ems.config.ObfuscationConfigTests ‑ return an error if connect.ems.obfuscation.fields contains invalid field names
com.celonis.kafka.connect.ems.config.ObfuscationConfigTests ‑ return an error if connect.ems.obfuscation.fields contains invalid field value
com.celonis.kafka.connect.ems.config.ObfuscationConfigTests ‑ return an error if connect.ems.obfuscation.method is empty
com.celonis.kafka.connect.ems.config.ObfuscationConfigTests ‑ return an error if connect.ems.obfuscation.method is missing
com.celonis.kafka.connect.ems.config.ObfuscationConfigTests ‑ return an error if connect.ems.obfuscation.sha512.salt is empty
com.celonis.kafka.connect.ems.config.ObfuscationConfigTests ‑ return an error if connect.ems.obfuscation.sha512.salt is missing
com.celonis.kafka.connect.ems.config.ObfuscationConfigTests ‑ return an error if the obfuscation type is incorrect
com.celonis.kafka.connect.ems.config.ObfuscationConfigTests ‑ return no obfuscation if connect.ems.obfuscation.fields is not provided
com.celonis.kafka.connect.ems.config.ObfuscationConfigTests ‑ return the obfuscation keys
com.celonis.kafka.connect.ems.config.OrderFieldConfigTest ‑ Default order field name when primary keys
com.celonis.kafka.connect.ems.config.OrderFieldConfigTest ‑ No order field and no inserter when no primary keys are set
com.celonis.kafka.connect.ems.config.OrderFieldConfigTest ‑ Use the provided sortable field and No-op inserter
com.celonis.kafka.connect.ems.config.ParquetConfigTest ‑ always set cleanup strategy to delete when inmemfs is set
com.celonis.kafka.connect.ems.config.ParquetConfigTest ‑ return an error if the value is smaller than 1
com.celonis.kafka.connect.ems.config.ParquetConfigTest ‑ return defaults if retry keys are missing
com.celonis.kafka.connect.ems.config.ParquetConfigTest ‑ return the given value
com.celonis.kafka.connect.ems.config.PrimaryKeysTests ‑ return NIL if connect.ems.data.primary.key is missing
com.celonis.kafka.connect.ems.config.PrimaryKeysTests ‑ return an error if connect.ems.data.primary.key contains invalid field names
com.celonis.kafka.connect.ems.config.PrimaryKeysTests ‑ return the primary keys
com.celonis.kafka.connect.ems.config.PropertiesHelperTest ‑ null and empty props mapped as empty
com.celonis.kafka.connect.ems.config.RetryTests ‑ return an error if retries is smaller than 1
com.celonis.kafka.connect.ems.config.RetryTests ‑ return an error if retry interval is smaller than 1s
com.celonis.kafka.connect.ems.config.RetryTests ‑ return defaults if retry keys are missing
com.celonis.kafka.connect.ems.config.RetryTests ‑ return the retry config
com.celonis.kafka.connect.ems.config.TargetTableTests ‑ return an error if connect.ems.target.table is empty
com.celonis.kafka.connect.ems.config.TargetTableTests ‑ return an error if connect.ems.target.table is missing
com.celonis.kafka.connect.ems.config.TargetTableTests ‑ return an error if connect.ems.target.table is not a string
com.celonis.kafka.connect.ems.config.TargetTableTests ‑ return an error if connect.ems.target.table is null
com.celonis.kafka.connect.ems.config.TargetTableTests ‑ return the target table provided by connect.ems.target.table
com.celonis.kafka.connect.ems.config.WorkingFolderTests ‑ return an error if connect.ems.tmp.dir is empty
com.celonis.kafka.connect.ems.config.WorkingFolderTests ‑ return an error if connect.ems.tmp.dir is missing
com.celonis.kafka.connect.ems.config.WorkingFolderTests ‑ return an error if connect.ems.tmp.dir is not a string
com.celonis.kafka.connect.ems.config.WorkingFolderTests ‑ return an error if connect.ems.tmp.dir is null
com.celonis.kafka.connect.ems.config.WorkingFolderTests ‑ return the target table provided with connect.ems.tmp.dir
com.celonis.kafka.connect.ems.conversion.AvroDataConverterTests ‑ convert complex structure
com.celonis.kafka.connect.ems.conversion.AvroDataConverterTests ‑ explode structure
com.celonis.kafka.connect.ems.conversion.JsonWithSchemaValueConverterTest ‑ convert struct
com.celonis.kafka.connect.ems.conversion.JsonWithSchemaValueConverterTest ‑ convert struct with decimalE
com.celonis.kafka.connect.ems.conversion.JsonWithSchemaValueConverterTest ‑ struct with optional field
com.celonis.kafka.connect.ems.conversion.SchemaLessJsonValueConverterTest ‑ convert nested schemaless JSON
com.celonis.kafka.connect.ems.conversion.SchemaLessJsonValueConverterTest ‑ empty schemaless JSON returns invalid input
com.celonis.kafka.connect.ems.converter.XmlConverterTest ‑ it should convert xml
com.celonis.kafka.connect.ems.converter.XmlConverterTest ‑ it should return null schema and value for null input (tombstone messages)
com.celonis.kafka.connect.ems.converter.XmlConverterTest ‑ it should throw a Connect DataException for deserialisation errors
com.celonis.kafka.connect.ems.model.DefaultCommitPolicyTest ‑ nothing to flush
com.celonis.kafka.connect.ems.model.DefaultCommitPolicyTest ‑ roll over after file size
com.celonis.kafka.connect.ems.model.DefaultCommitPolicyTest ‑ trigger flush once records count is reached
com.celonis.kafka.connect.ems.model.DefaultCommitPolicyTest ‑ trigger flush when time limit is reached
com.celonis.kafka.connect.ems.model.FixObfuscationTest ‑ null returns null
com.celonis.kafka.connect.ems.model.FixObfuscationTest ‑ returns the expected value
com.celonis.kafka.connect.ems.model.Sha1ObfuscationTest ‑ null returns null
com.celonis.kafka.connect.ems.model.Sha1ObfuscationTest ‑ returns the expected value
com.celonis.kafka.connect.ems.model.Sha512ObfuscationTest ‑ null returns null
com.celonis.kafka.connect.ems.model.Sha512ObfuscationTest ‑ returns the expected value
com.celonis.kafka.connect.ems.model.Sha512RandomSaltObfuscationTest ‑ null returns null
com.celonis.kafka.connect.ems.model.Sha512RandomSaltObfuscationTest ‑ rotates the values
com.celonis.kafka.connect.ems.obfuscation.ObfuscationTests ‑ fails when it does not have 'value' for array field
com.celonis.kafka.connect.ems.obfuscation.ObfuscationTests ‑ fails when the obfuscation resolves to non string
com.celonis.kafka.connect.ems.obfuscation.ObfuscationTests ‑ handles null players for com.celonis.kafka.connect.ems.obfuscation.OptionalTeam$
com.celonis.kafka.connect.ems.obfuscation.ObfuscationTests ‑ obfuscates com.celonis.kafka.connect.ems.obfuscation.OptionalTeam$ players name
com.celonis.kafka.connect.ems.obfuscation.ObfuscationTests ‑ obfuscates com.celonis.kafka.connect.ems.obfuscation.Player name
com.celonis.kafka.connect.ems.obfuscation.ObfuscationTests ‑ obfuscates com.celonis.kafka.connect.ems.obfuscation.Team player name
com.celonis.kafka.connect.ems.obfuscation.ObfuscationTests ‑ returns an error when the obfuscation path resolves to a non string when parent path involves nullable fields
com.celonis.kafka.connect.ems.sink.EmsSinkConfiguratorTest ‑ should extract name from pros
com.celonis.kafka.connect.ems.sink.EmsSinkConfiguratorTest ‑ should return default name if none configured
com.celonis.kafka.connect.ems.sink.EmsSinkConfiguratorTest ‑ throws exception when 65000 is too big
com.celonis.kafka.connect.ems.sink.EmsSinkConfiguratorTest ‑ throws exception when connect.ems.commit.records is negative
com.celonis.kafka.connect.ems.sink.EmsSinkConfiguratorTest ‑ throws exception when connect.ems.commit.size.bytes less than 100KB
com.celonis.kafka.connect.ems.sink.EmsSinkConnectorTest ‑ starts an EMS sink connector
com.celonis.kafka.connect.ems.sink.EmsSinkConnectorTest ‑ throws an exception for invalid config value
com.celonis.kafka.connect.ems.sink.EmsSinkConnectorTest ‑ throws an exception for missing required connector config
com.celonis.kafka.connect.ems.sink.EmsSinkTaskObfuscationTest ‑ failed obfuscation raises an exception
com.celonis.kafka.connect.ems.storage.EmsUploadResponseTest ‑ should decode valid emsUploadResponse
com.celonis.kafka.connect.ems.storage.EmsUploaderTests ‑ handles invalid authorization
com.celonis.kafka.connect.ems.storage.EmsUploaderTests ‑ handles non json responses
com.celonis.kafka.connect.ems.storage.EmsUploaderTests ‑ uploads the file
com.celonis.kafka.connect.ems.storage.EmsUploaderTests ‑ uploads the file through an authenticated proxy
com.celonis.kafka.connect.ems.storage.EmsUploaderTests ‑ uploads the file through an unauthenticated proxy
com.celonis.kafka.connect.ems.storage.EmsUploaderUriTests ‑ creates the URI with all params
com.celonis.kafka.connect.ems.storage.EmsUploaderUriTests ‑ creates the URI with connection
com.celonis.kafka.connect.ems.storage.EmsUploaderUriTests ‑ creates the URI with fallback varchar length
com.celonis.kafka.connect.ems.storage.EmsUploaderUriTests ‑ creates the URI with the pks
com.celonis.kafka.connect.ems.storage.EmsUploaderUriTests ‑ creates the URI without the connection
com.celonis.kafka.connect.ems.storage.EmsWriterTests ‑ failing to write a record does not change the state
com.celonis.kafka.connect.ems.storage.EmsWriterTests ‑ shouldFlush returns false when commit policy remains unmatched
com.celonis.kafka.connect.ems.storage.EmsWriterTests ‑ shouldFlush returns true once commit policy is matched
com.celonis.kafka.connect.ems.storage.EmsWriterTests ‑ shouldRollover returns false when schema changes and format writer sets rollover on schema change to false
com.celonis.kafka.connect.ems.storage.EmsWriterTests ‑ shouldRollover returns false when schema remains unchanged and format writer sets rollover on schema change to true
com.celonis.kafka.connect.ems.storage.EmsWriterTests ‑ shouldRollover returns true when schema changes and format writer sets rollover on schema change to true
com.celonis.kafka.connect.ems.storage.EmsWriterTests ‑ writes a records and updates the state
com.celonis.kafka.connect.ems.storage.EmsWriterTests ‑ writes only records with the offset greater than the last offset one
com.celonis.kafka.connect.ems.storage.FileSystemOperationsTests ‑ create the output path
com.celonis.kafka.connect.ems.storage.FileSystemOperationsTests ‑ delete a flat folder
com.celonis.kafka.connect.ems.storage.FileSystemOperationsTests ‑ delete a nested folder
com.celonis.kafka.connect.ems.storage.FileSystemOperationsTests ‑ topic partition is cleaned
com.celonis.kafka.connect.ems.storage.PrimaryKeysValidatorTests ‑ accept a message with primary key being null - allow null enabled
com.celonis.kafka.connect.ems.storage.PrimaryKeysValidatorTests ‑ empty pks return success
com.celonis.kafka.connect.ems.storage.PrimaryKeysValidatorTests ‑ return an error when at least one of the PK is null - allow null disabled
com.celonis.kafka.connect.ems.storage.PrimaryKeysValidatorTests ‑ returns an error if one of the fields is not present
com.celonis.kafka.connect.ems.storage.PrimaryKeysValidatorTests ‑ returns an error if the field is not present
com.celonis.kafka.connect.ems.storage.PrimaryKeysValidatorTests ‑ validates pks are present
com.celonis.kafka.connect.ems.storage.UploadRequestTest ‑ it builds filename from writer state
com.celonis.kafka.connect.ems.storage.WriterManagerTests ‑ cleans up on topic partitions allocated
com.celonis.kafka.connect.ems.storage.WriterManagerTests ‑ commit data when enough data has been accumulated
com.celonis.kafka.connect.ems.storage.WriterManagerTests ‑ commit data when there is a schema change
com.celonis.kafka.connect.ems.storage.WriterManagerTests ‑ commit data when there is a schema change after a flush (i.e. when current writer state is empty)
com.celonis.kafka.connect.ems.storage.WriterManagerTests ‑ does not upload data if the writers have nothing to flush
com.celonis.kafka.connect.ems.storage.WriterManagerTests ‑ handle schema change when a column is dropped
com.celonis.kafka.connect.ems.storage.WriterManagerTests ‑ keep the file once it has been uploaded
com.celonis.kafka.connect.ems.storage.WriterManagerTests ‑ opens a writer on the first record for the topic partition
com.celonis.kafka.connect.ems.storage.WriterManagerTests ‑ returns an empty Map when there's no committed offset
com.celonis.kafka.connect.ems.storage.WriterManagerTests ‑ returns the latest committed offsets
com.celonis.kafka.connect.ems.storage.WriterManagerTests ‑ the uploader throws an exception the state is not corrupted on attempting to write again
com.celonis.kafka.connect.ems.storage.formats.ListExploderTest ‑ explodes a container struct containing array
com.celonis.kafka.connect.ems.storage.formats.ListExploderTest ‑ explodes a container struct containing list
com.celonis.kafka.connect.ems.storage.formats.NoOpExploderTest ‑ returns a singleton list
com.celonis.kafka.connect.ems.storage.formats.ParquetFormatWriterTests ‑ flush to disk after N records
com.celonis.kafka.connect.ems.storage.formats.ParquetFormatWriterTests ‑ returns 0 on file size after initialization
com.celonis.kafka.connect.ems.storage.formats.ParquetFormatWriterTests ‑ rollover on schema change returns true
com.celonis.kafka.connect.ems.storage.formats.ParquetFormatWriterTests ‑ writes a schemaless JSON
com.celonis.kafka.connect.ems.storage.formats.ParquetFormatWriterTests ‑ writes a struct to a file and returns the new non-zero file size
com.celonis.kafka.connect.schema.StructSchemaAlignmentTest ‑ aligns an array nested into a map to the super-schema
com.celonis.kafka.connect.schema.StructSchemaAlignmentTest ‑ aligns arrays of structs to the super-schema
com.celonis.kafka.connect.schema.StructSchemaAlignmentTest ‑ aligns maps of structs to the super-schema
com.celonis.kafka.connect.schema.StructSchemaAlignmentTest ‑ aligns nested arrays to the super-schema
com.celonis.kafka.connect.schema.StructSchemaAlignmentTest ‑ aligns nested struct values to the super-schema
com.celonis.kafka.connect.schema.StructSchemaEvolutionTest ‑ ArrayEvolutionWithDifferentStructFields
com.celonis.kafka.connect.schema.StructSchemaEvolutionTest ‑ MapEvolutionWithDifferentStructFields
com.celonis.kafka.connect.schema.StructSchemaEvolutionTest ‑ RecursiveArrayEvolutionWithDifferentStructFields
com.celonis.kafka.connect.schema.StructSchemaEvolutionTest ‑ SchemaEvolutionWithAdditionalRecordFields
com.celonis.kafka.connect.schema.StructSchemaEvolutionTest ‑ SchemaEvolutionWithAdditionalStructCurrentField
com.celonis.kafka.connect.schema.StructSchemaEvolutionTest ‑ SchemaEvolutionWithAdditionalStructRecordField
com.celonis.kafka.connect.schema.StructSchemaEvolutionTest ‑ SchemaEvolutionWithCommonStructFields
com.celonis.kafka.connect.schema.StructSchemaEvolutionTest ‑ SchemaEvolutionWithEmptyRecordFields
com.celonis.kafka.connect.schema.StructSchemaEvolutionTest ‑ avroLogicalTypeAwareness
com.celonis.kafka.connect.schema.StructSchemaEvolutionTest ‑ fieldOrderIsPreserved
com.celonis.kafka.connect.schema.StructSchemaEvolutionTest ‑ schema evolution with common primitive fields
com.celonis.kafka.connect.schema.StructSchemaEvolutionTest ‑ schema evolution with empty current fields
com.celonis.kafka.connect.schema.StructSchemaEvolutionTest ‑ subSchemaMatchesItsPreviousVersion
com.celonis.kafka.connect.schema.StructSchemaEvolutionTest ‑ testSchemaEvolutionPreservesFieldOptionality
com.celonis.kafka.connect.schema.StructSchemaEvolutionTest ‑ throws exception For Different SchemaTypes with same name
com.celonis.kafka.connect.transform.FlattenerConfigTest ‑ returns None unless explicitly enabled
com.celonis.kafka.connect.transform.FlattenerConfigTest ‑ returns an error message when a flattener setting is supplied without the flattener being enabled
com.celonis.kafka.connect.transform.FlattenerConfigTest ‑ returns an error message when jsonblob.chunks is set without a value fallback varchar length
com.celonis.kafka.connect.transform.FlattenerConfigTest ‑ returns config value when all the depending configs are supplied
com.celonis.kafka.connect.transform.InferSchemaAndNormaliseValueTest ‑ Fails when a map contains an empty key
com.celonis.kafka.connect.transform.InferSchemaAndNormaliseValueTest ‑ Fails with non-empty heterogeneous collections
com.celonis.kafka.connect.transform.InferSchemaAndNormaliseValueTest ‑ Infers simple collections
com.celonis.kafka.connect.transform.InferSchemaAndNormaliseValueTest ‑ Infers simple maps of primitives
com.celonis.kafka.connect.transform.InferSchemaAndNormaliseValueTest ‑ Infers simple maps of strings
com.celonis.kafka.connect.transform.InferSchemaAndNormaliseValueTest ‑ Infers the schema of simple primitives
com.celonis.kafka.connect.transform.InferSchemaAndNormaliseValueTest ‑ Normalisation transforms maps nested in arrays
com.celonis.kafka.connect.transform.InferSchemaAndNormaliseValueTest ‑ Normalisation transforms maps nested in maps
com.celonis.kafka.connect.transform.InferSchemaAndNormaliseValueTest ‑ Succeeds with empty collections
com.celonis.kafka.connect.transform.InferSchemaAndNormaliseValueTest ‑ infers nested object's schema
com.celonis.kafka.connect.transform.InferSchemaAndNormaliseValueTest ‑ normalises a schemaless JSON
com.celonis.kafka.connect.transform.InferSchemaAndNormaliseValueTest ‑ omits fields with a null value
com.celonis.kafka.connect.transform.InferSchemaAndNormaliseValueTest ‑ returns None when encountering an unexpected value
com.celonis.kafka.connect.transform.RecordTransformerTest ‑ With Chunking disabled, heterogeneous arrays prevent flattening
com.celonis.kafka.connect.transform.RecordTransformerTest ‑ With Chunking disabled, heterogeneous arrays prevents flattening, even with discardCollection enabled
com.celonis.kafka.connect.transform.RecordTransformerTest ‑ With Chunking enabled, JSON with empty keys is handled properly
com.celonis.kafka.connect.transform.RecordTransformerTest ‑ With Chunking enabled, heterogeneous arrays are handled properly
com.celonis.kafka.connect.transform.RecordTransformerTest ‑ With decimal conversion enabled, big decimals are converted into doubles
com.celonis.kafka.connect.transform.RecordTransformerTest ‑ evolves target schema and aligns sunk record value to it
com.celonis.kafka.connect.transform.RecordTransformerTest ‑ resets schema when schema evolution fails due to a type error
com.celonis.kafka.connect.transform.conversion.ConnectConversionTest ‑ Build conversion from config
com.celonis.kafka.connect.transform.conversion.ConnectConversionTest ‑ Build noop conversion if convertDecimalsToFloat
com.celonis.kafka.connect.transform.conversion.DecimalToFloatConversionTest ‑ it converts decimal schemas to float64 schemas
com.celonis.kafka.connect.transform.conversion.DecimalToFloatConversionTest ‑ it converts decimal values to doubles
com.celonis.kafka.connect.transform.conversion.DecimalToFloatConversionTest ‑ it converts optional decimal values to doubles
com.celonis.kafka.connect.transform.conversion.DecimalToFloatConversionTest ‑ it does nothing on non-decimal primitive optional schemas and values
com.celonis.kafka.connect.transform.conversion.DecimalToFloatConversionTest ‑ it does nothing on non-decimal primitive schemas and values
com.celonis.kafka.connect.transform.conversion.DecimalToFloatConversionTest ‑ it is not recursive on lists
com.celonis.kafka.connect.transform.conversion.DecimalToFloatConversionTest ‑ it is not recursive on maps
com.celonis.kafka.connect.transform.conversion.DecimalToFloatConversionTest ‑ it is not recursive on structs
com.celonis.kafka.connect.transform.conversion.RecursiveConversionTest ‑ it is  recursive on collections
com.celonis.kafka.connect.transform.conversion.RecursiveConversionTest ‑ it is  recursive on maps
com.celonis.kafka.connect.transform.conversion.RecursiveConversionTest ‑ it is  recursive on structs
com.celonis.kafka.connect.transform.fields.EmbeddedKafkaMetadataFieldInserterTest ‑ FieldInserter returns a CelonisOrder inserter if flag is set to false but order fields is set to __celonis_order
com.celonis.kafka.connect.transform.fields.EmbeddedKafkaMetadataFieldInserterTest ‑ FieldInserter returns a noop if flag is set to false
com.celonis.kafka.connect.transform.fields.EmbeddedKafkaMetadataFieldInserterTest ‑ fieldInserter adds embedded metadata and celonis order when both are required
com.celonis.kafka.connect.transform.fields.EmbeddedKafkaMetadataFieldInserterTest ‑ fieldInserter adds partition and offset to a non-empty struct
com.celonis.kafka.connect.transform.flatten.ChunkedJsonBlobFlattenerTest ‑ chunk-encodes hashmaps
com.celonis.kafka.connect.transform.flatten.ChunkedJsonBlobFlattenerTest ‑ chunk-encodes strings
com.celonis.kafka.connect.transform.flatten.ChunkedJsonBlobFlattenerTest ‑ chunk-encodes structs
com.celonis.kafka.connect.transform.flatten.ChunkedJsonBlobFlattenerTest ‑ does not raise errors when payloadBytes is exactly maxChunks * fallbackVarcharLength
com.celonis.kafka.connect.transform.flatten.ChunkedJsonBlobFlattenerTest ‑ generates a schema based on the configured jsonBlobChunks maxChunks value
com.celonis.kafka.connect.transform.flatten.ChunkedJsonBlobFlattenerTest ‑ raises an error even when payloadBytes slightly exceeds maxChunks * fallbackVarcharLength
com.celonis.kafka.connect.transform.flatten.ChunkedJsonBlobFlattenerTest ‑ raises an error if maxChunks in JsonBlobChunkConfig is insufficient
com.celonis.kafka.connect.transform.flatten.FlattenerTest ‑ With a JsonChunk config, a JsonChunkFlattener is used
com.celonis.kafka.connect.transform.flatten.FlattenerTest ‑ Without a JsonChunk config, a StructFlattener nested in a NormalisingFlattener is used
com.celonis.kafka.connect.transform.flatten.FlattenerTest ‑ Without a config, a noOp flattener is used
com.celonis.kafka.connect.transform.flatten.SchemaFlattenerTest ‑ drops arrays/maps when discardCollections is set
com.celonis.kafka.connect.transform.flatten.SchemaFlattenerTest ‑ flattens a schema making all primitives optional
com.celonis.kafka.connect.transform.flatten.SchemaFlattenerTest ‑ leaves a top-level collection untouched even when discardCollections is set
com.celonis.kafka.connect.transform.flatten.SchemaFlattenerTest ‑ replaces ENUMs coming from AVRO to Strings
com.celonis.kafka.connect.transform.flatten.SchemaFlattenerTest ‑ sanitises keys as AVRO compliant field names
com.celonis.kafka.connect.transform.flatten.SchemaFlattenerTest ‑ turns arrays and maps into optional string fields
com.celonis.kafka.connect.transform.flatten.StructFlattenerTest ‑ JSON encodes collection of AVRO records
com.celonis.kafka.connect.transform.flatten.StructFlattenerTest ‑ JSON encodes collection of JSON records
com.celonis.kafka.connect.transform.flatten.StructFlattenerTest ‑ JSON encodes collection of JSON records - union nested null
com.celonis.kafka.connect.transform.flatten.StructFlattenerTest ‑ do nothing on a primitive
com.celonis.kafka.connect.transform.flatten.StructFlattenerTest ‑ drops arrays/maps when 'discardCollections' is set
com.celonis.kafka.connect.transform.flatten.StructFlattenerTest ‑ flattens nested fields
com.celonis.kafka.connect.transform.flatten.StructFlattenerTest ‑ leaves top level collections untouched when 'discardCollections' is set
com.celonis.kafka.connect.transform.flatten.StructFlattenerTest ‑ transforms arrays and maps of primitives into strings
com.celonis.kafka.connect.transform.flatten.StructFlattenerTest ‑ when the schema is inferred, flattens nested maps instead than json-encoding them