fix: fix now-forbidden warnings 🙈

Author: fbiville

legacy-connectors/src/test/kotlin/streams/kafka/connect/source/LegacyNeo4jSourceIT.kt

@@ -65,6 +65,7 @@ class LegacyNeo4jSourceIT {
             mapOf("execId" to executionId))
         .consume()
 
+    @Suppress("DEPRECATION")
     TopicVerifier.create(consumer)
         .expectMessageValueMatching { value ->
           value.asMap().excludingKeys("timestamp") ==

source-connector/src/test/kotlin/org/neo4j/connectors/kafka/source/Neo4jSourceIT.kt

@@ -65,6 +65,7 @@ class Neo4jSourceIT {
             mapOf("execId" to executionId))
         .consume()
 
+    @Suppress("DEPRECATION")
     TopicVerifier.create(consumer)
         .expectMessageValueMatching { value ->
           value.asMap().excludingKeys("timestamp") ==

source/src/main/kotlin/org/neo4j/connectors/kafka/source/Neo4jCdcKeyStrategy.kt

@@ -77,7 +77,7 @@ enum class Neo4jCdcKeyStrategy {
       val eventData = value.get("event")
       if (eventData !is Struct) {
         throw IllegalArgumentException(
-            "expected event attribute to be a struct, but got: ${value?.javaClass}",
+            "expected event attribute to be a struct, but got: ${value.javaClass}",
         )
       }
       return eventData

testing/src/main/kotlin/org/neo4j/connectors/kafka/testing/assertions/TopicVerifier.kt

@@ -33,6 +33,7 @@ class TopicVerifier<K, V>(private val consumer: KafkaConsumer<K, V>) {
   private var messagePredicates = mutableListOf<Predicate<ConsumerRecord<K, V>>>()
 
   fun assertMessageValue(assertion: (V) -> Unit): TopicVerifier<K, V> {
+    @Suppress("DEPRECATION")
     return expectMessageValueMatching { value ->
       try {
         assertion(value)