com.celonis.kafka.connect.ems.ErrorPolicyTests ‑ continue error policy
com.celonis.kafka.connect.ems.ErrorPolicyTests ‑ continue on invalid input
com.celonis.kafka.connect.ems.ErrorPolicyTests ‑ honours connect.ems.sink.put.timeout.ms
com.celonis.kafka.connect.ems.ErrorPolicyTests ‑ retry error policy
com.celonis.kafka.connect.ems.ErrorPolicyTests ‑ throw error policy
com.celonis.kafka.connect.ems.OrderFieldTests ‑ Introduce the auto generate sortable field when a PKs list was provided and embeded Kafka metadata is disabled
com.celonis.kafka.connect.ems.OrderFieldTests ‑ The order field is not inserted when PK was not set and embedded Kafka metadata is disabled
com.celonis.kafka.connect.ems.OrderFieldTests ‑ Uses the provided PK field when PK was set
com.celonis.kafka.connect.ems.ParquetFileSizeTest ‑ commit.size.bytes > uploaded file size bytes < (row.group.size.bytes + commit.size.bytes)
com.celonis.kafka.connect.ems.ParquetTests ‑ generate parquet file with obfuscated fields
com.celonis.kafka.connect.ems.ParquetTests ‑ perform Decimal to Double conversion when flag is enabled
com.celonis.kafka.connect.ems.ParquetTests ‑ reads records from generated parquet file
com.celonis.kafka.connect.ems.ParquetTests ‑ works AVRO logical types in the input avro topic
com.celonis.kafka.connect.ems.SchemaChangeTests ‑ schema change just after a flush
com.celonis.kafka.connect.ems.SchemaChangeTests ‑ schema change when previous file has not been flushed yet
com.celonis.kafka.connect.ems.SchemaCompatibilityTests ‑ handle schema column drop
com.celonis.kafka.connect.ems.Socks5ProxyTests ‑ socks5 proxy support
com.celonis.kafka.connect.ems.Socks5ProxyTests ‑ socks5 proxy with authentication
com.celonis.kafka.connect.ems.XmlTests ‑ reads xml records