pjfanning commented on PR #296: URL: https://github.com/apache/pekko-connectors-kafka/pull/296#issuecomment-2754221603
I fixed the compile issues in the main source but now there are quite a few in the test source. ``` [error] /home/runner/work/pekko-connectors-kafka/pekko-connectors-kafka/tests/src/test/scala/org/apache/pekko/kafka/internal/CommittingProducerSinkSpec.scala:84:20: overloaded method constructor MockProducer with alternatives: [error] ()org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: Boolean,x$2: org.apache.kafka.clients.producer.Partitioner,x$3: org.apache.kafka.common.serialization.Serializer[String],x$4: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: org.apache.kafka.common.Cluster,x$2: Boolean,x$3: org.apache.kafka.clients.producer.Partitioner,x$4: org.apache.kafka.common.serialization.Serializer[String],x$5: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] [error] cannot be applied to (Boolean, org.apache.kafka.common.serialization.StringSerializer, org.apache.kafka.common.serialization.StringSerializer) [error] val producer = new MockProducer[String, String](true, new StringSerializer, new StringSerializer) [error] ^ [error] /home/runner/work/pekko-connectors-kafka/pekko-connectors-kafka/tests/src/test/scala/org/apache/pekko/kafka/internal/CommittingProducerSinkSpec.scala:120:20: overloaded method constructor MockProducer with alternatives: [error] ()org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: Boolean,x$2: org.apache.kafka.clients.producer.Partitioner,x$3: org.apache.kafka.common.serialization.Serializer[String],x$4: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: org.apache.kafka.common.Cluster,x$2: Boolean,x$3: org.apache.kafka.clients.producer.Partitioner,x$4: org.apache.kafka.common.serialization.Serializer[String],x$5: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] [error] cannot be applied to (Boolean, org.apache.kafka.common.serialization.StringSerializer, org.apache.kafka.common.serialization.StringSerializer) [error] val producer = new MockProducer[String, String](true, new StringSerializer, new StringSerializer) [error] ^ [error] /home/runner/work/pekko-connectors-kafka/pekko-connectors-kafka/tests/src/test/scala/org/apache/pekko/kafka/internal/CommittingProducerSinkSpec.scala:160:20: overloaded method constructor MockProducer with alternatives: [error] ()org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: Boolean,x$2: org.apache.kafka.clients.producer.Partitioner,x$3: org.apache.kafka.common.serialization.Serializer[String],x$4: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: org.apache.kafka.common.Cluster,x$2: Boolean,x$3: org.apache.kafka.clients.producer.Partitioner,x$4: org.apache.kafka.common.serialization.Serializer[String],x$5: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] [error] cannot be applied to (Boolean, org.apache.kafka.common.serialization.StringSerializer, org.apache.kafka.common.serialization.StringSerializer) [error] val producer = new MockProducer[String, String](true, new StringSerializer, new StringSerializer) [error] ^ [error] /home/runner/work/pekko-connectors-kafka/pekko-connectors-kafka/tests/src/test/scala/org/apache/pekko/kafka/internal/CommittingProducerSinkSpec.scala:[194](https://github.com/apache/pekko-connectors-kafka/actions/runs/14083074066/job/39440313548?pr=296#step:6:195):20: overloaded method constructor MockProducer with alternatives: [error] ()org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: Boolean,x$2: org.apache.kafka.clients.producer.Partitioner,x$3: org.apache.kafka.common.serialization.Serializer[String],x$4: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: org.apache.kafka.common.Cluster,x$2: Boolean,x$3: org.apache.kafka.clients.producer.Partitioner,x$4: org.apache.kafka.common.serialization.Serializer[String],x$5: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] [error] cannot be applied to (Boolean, org.apache.kafka.common.serialization.StringSerializer, org.apache.kafka.common.serialization.StringSerializer) [error] val producer = new MockProducer[String, String](true, new StringSerializer, new StringSerializer) [error] ^ [error] /home/runner/work/pekko-connectors-kafka/pekko-connectors-kafka/tests/src/test/scala/org/apache/pekko/kafka/internal/CommittingProducerSinkSpec.scala:229:20: overloaded method constructor MockProducer with alternatives: [error] ()org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: Boolean,x$2: org.apache.kafka.clients.producer.Partitioner,x$3: org.apache.kafka.common.serialization.Serializer[String],x$4: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: org.apache.kafka.common.Cluster,x$2: Boolean,x$3: org.apache.kafka.clients.producer.Partitioner,x$4: org.apache.kafka.common.serialization.Serializer[String],x$5: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] [error] cannot be applied to (Boolean, org.apache.kafka.common.serialization.StringSerializer, org.apache.kafka.common.serialization.StringSerializer) [error] val producer = new MockProducer[String, String](true, new StringSerializer, new StringSerializer) [error] ^ [error] /home/runner/work/pekko-connectors-kafka/pekko-connectors-kafka/tests/src/test/scala/org/apache/pekko/kafka/internal/CommittingProducerSinkSpec.scala:262:20: overloaded method constructor MockProducer with alternatives: [error] ()org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: Boolean,x$2: org.apache.kafka.clients.producer.Partitioner,x$3: org.apache.kafka.common.serialization.Serializer[String],x$4: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: org.apache.kafka.common.Cluster,x$2: Boolean,x$3: org.apache.kafka.clients.producer.Partitioner,x$4: org.apache.kafka.common.serialization.Serializer[String],x$5: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] [error] cannot be applied to (Boolean, org.apache.kafka.common.serialization.StringSerializer, org.apache.kafka.common.serialization.StringSerializer) [error] val producer = new MockProducer[String, String](true, new StringSerializer, new StringSerializer) [error] ^ [error] /home/runner/work/pekko-connectors-kafka/pekko-connectors-kafka/tests/src/test/scala/org/apache/pekko/kafka/internal/CommittingProducerSinkSpec.scala:295:20: overloaded method constructor MockProducer with alternatives: [error] ()org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: Boolean,x$2: org.apache.kafka.clients.producer.Partitioner,x$3: org.apache.kafka.common.serialization.Serializer[String],x$4: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: org.apache.kafka.common.Cluster,x$2: Boolean,x$3: org.apache.kafka.clients.producer.Partitioner,x$4: org.apache.kafka.common.serialization.Serializer[String],x$5: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] [error] cannot be applied to (Boolean, org.apache.kafka.common.serialization.StringSerializer, org.apache.kafka.common.serialization.StringSerializer) [error] val producer = new MockProducer[String, String](true, new StringSerializer, new StringSerializer) [error] ^ [error] /home/runner/work/pekko-connectors-kafka/pekko-connectors-kafka/tests/src/test/scala/org/apache/pekko/kafka/internal/CommittingProducerSinkSpec.scala:331:20: overloaded method constructor MockProducer with alternatives: [error] ()org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: Boolean,x$2: org.apache.kafka.clients.producer.Partitioner,x$3: org.apache.kafka.common.serialization.Serializer[String],x$4: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: org.apache.kafka.common.Cluster,x$2: Boolean,x$3: org.apache.kafka.clients.producer.Partitioner,x$4: org.apache.kafka.common.serialization.Serializer[String],x$5: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] [error] cannot be applied to (Boolean, org.apache.kafka.common.serialization.StringSerializer, org.apache.kafka.common.serialization.StringSerializer) [error] val producer = new MockProducer[String, String](true, new StringSerializer, new StringSerializer) [error] ^ [error] /home/runner/work/pekko-connectors-kafka/pekko-connectors-kafka/tests/src/test/scala/org/apache/pekko/kafka/internal/CommittingProducerSinkSpec.scala:367:20: overloaded method constructor MockProducer with alternatives: [error] ()org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: Boolean,x$2: org.apache.kafka.clients.producer.Partitioner,x$3: org.apache.kafka.common.serialization.Serializer[String],x$4: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: org.apache.kafka.common.Cluster,x$2: Boolean,x$3: org.apache.kafka.clients.producer.Partitioner,x$4: org.apache.kafka.common.serialization.Serializer[String],x$5: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] [error] cannot be applied to (Boolean, org.apache.kafka.common.serialization.StringSerializer, org.apache.kafka.common.serialization.StringSerializer) [error] val producer = new MockProducer[String, String](true, new StringSerializer, new StringSerializer) [error] ^ [error] /home/runner/work/pekko-connectors-kafka/pekko-connectors-kafka/tests/src/test/scala/org/apache/pekko/kafka/internal/CommittingProducerSinkSpec.scala:407:20: overloaded method constructor MockProducer with alternatives: [error] ()org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: Boolean,x$2: org.apache.kafka.clients.producer.Partitioner,x$3: org.apache.kafka.common.serialization.Serializer[String],x$4: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: org.apache.kafka.common.Cluster,x$2: Boolean,x$3: org.apache.kafka.clients.producer.Partitioner,x$4: org.apache.kafka.common.serialization.Serializer[String],x$5: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] [error] cannot be applied to (Boolean, org.apache.kafka.common.serialization.StringSerializer, org.apache.kafka.common.serialization.StringSerializer) [error] val producer = new MockProducer[String, String](true, new StringSerializer, new StringSerializer) [error] ^ [error] /home/runner/work/pekko-connectors-kafka/pekko-connectors-kafka/tests/src/test/scala/org/apache/pekko/kafka/internal/CommittingProducerSinkSpec.scala:444:20: overloaded method constructor MockProducer with alternatives: [error] ()org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: Boolean,x$2: org.apache.kafka.clients.producer.Partitioner,x$3: org.apache.kafka.common.serialization.Serializer[String],x$4: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: org.apache.kafka.common.Cluster,x$2: Boolean,x$3: org.apache.kafka.clients.producer.Partitioner,x$4: org.apache.kafka.common.serialization.Serializer[String],x$5: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] [error] cannot be applied to (Boolean, org.apache.kafka.common.serialization.StringSerializer, org.apache.kafka.common.serialization.StringSerializer) [error] val producer = new MockProducer[String, String](false, new StringSerializer, new StringSerializer) [error] ^ [error] /home/runner/work/pekko-connectors-kafka/pekko-connectors-kafka/tests/src/test/scala/org/apache/pekko/kafka/internal/CommittingProducerSinkSpec.scala:483:20: overloaded method constructor MockProducer with alternatives: [error] ()org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: Boolean,x$2: org.apache.kafka.clients.producer.Partitioner,x$3: org.apache.kafka.common.serialization.Serializer[String],x$4: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: org.apache.kafka.common.Cluster,x$2: Boolean,x$3: org.apache.kafka.clients.producer.Partitioner,x$4: org.apache.kafka.common.serialization.Serializer[String],x$5: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] [error] cannot be applied to (Boolean, org.apache.kafka.common.serialization.StringSerializer, org.apache.kafka.common.serialization.StringSerializer) [error] val producer = new MockProducer[String, String](false, new StringSerializer, new StringSerializer) [error] ^ [error] /home/runner/work/pekko-connectors-kafka/pekko-connectors-kafka/tests/src/test/scala/org/apache/pekko/kafka/internal/CommittingProducerSinkSpec.scala:526:20: overloaded method constructor MockProducer with alternatives: [error] ()org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: Boolean,x$2: org.apache.kafka.clients.producer.Partitioner,x$3: org.apache.kafka.common.serialization.Serializer[String],x$4: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: org.apache.kafka.common.Cluster,x$2: Boolean,x$3: org.apache.kafka.clients.producer.Partitioner,x$4: org.apache.kafka.common.serialization.Serializer[String],x$5: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] [error] cannot be applied to (Boolean, org.apache.kafka.common.serialization.StringSerializer, org.apache.kafka.common.serialization.StringSerializer) [error] val producer = new MockProducer[String, String](false, new StringSerializer, new StringSerializer) [error] ^ [error] /home/runner/work/pekko-connectors-kafka/pekko-connectors-kafka/tests/src/test/scala/org/apache/pekko/kafka/internal/CommittingProducerSinkSpec.scala:572:20: overloaded method constructor MockProducer with alternatives: [error] ()org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: Boolean,x$2: org.apache.kafka.clients.producer.Partitioner,x$3: org.apache.kafka.common.serialization.Serializer[String],x$4: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: org.apache.kafka.common.Cluster,x$2: Boolean,x$3: org.apache.kafka.clients.producer.Partitioner,x$4: org.apache.kafka.common.serialization.Serializer[String],x$5: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] [error] cannot be applied to (Boolean, org.apache.kafka.common.serialization.StringSerializer, org.apache.kafka.common.serialization.StringSerializer) [error] val producer = new MockProducer[String, String](true, new StringSerializer, new StringSerializer) [error] ^ [error] /home/runner/work/pekko-connectors-kafka/pekko-connectors-kafka/tests/src/test/scala/org/apache/pekko/kafka/internal/CommittingProducerSinkSpec.scala:605:20: overloaded method constructor MockProducer with alternatives: [error] ()org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: Boolean,x$2: org.apache.kafka.clients.producer.Partitioner,x$3: org.apache.kafka.common.serialization.Serializer[String],x$4: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: org.apache.kafka.common.Cluster,x$2: Boolean,x$3: org.apache.kafka.clients.producer.Partitioner,x$4: org.apache.kafka.common.serialization.Serializer[String],x$5: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] [error] cannot be applied to (Boolean, org.apache.kafka.common.serialization.StringSerializer, org.apache.kafka.common.serialization.StringSerializer) [error] val producer = new MockProducer[String, String](true, new StringSerializer, new StringSerializer) [error] ^ [error] /home/runner/work/pekko-connectors-kafka/pekko-connectors-kafka/tests/src/test/scala/org/apache/pekko/kafka/internal/CommittingProducerSinkSpec.scala:643:20: overloaded method constructor MockProducer with alternatives: [error] ()org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: Boolean,x$2: org.apache.kafka.clients.producer.Partitioner,x$3: org.apache.kafka.common.serialization.Serializer[String],x$4: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: org.apache.kafka.common.Cluster,x$2: Boolean,x$3: org.apache.kafka.clients.producer.Partitioner,x$4: org.apache.kafka.common.serialization.Serializer[String],x$5: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] [error] cannot be applied to (Boolean, org.apache.kafka.common.serialization.StringSerializer, org.apache.kafka.common.serialization.StringSerializer) [error] val producer = new MockProducer[String, String](true, new StringSerializer, new StringSerializer) [error] ^ [error] /home/runner/work/pekko-connectors-kafka/pekko-connectors-kafka/tests/src/test/scala/org/apache/pekko/kafka/internal/CommittingProducerSinkSpec.scala:677:20: overloaded method constructor MockProducer with alternatives: [error] ()org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: Boolean,x$2: org.apache.kafka.clients.producer.Partitioner,x$3: org.apache.kafka.common.serialization.Serializer[String],x$4: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: org.apache.kafka.common.Cluster,x$2: Boolean,x$3: org.apache.kafka.clients.producer.Partitioner,x$4: org.apache.kafka.common.serialization.Serializer[String],x$5: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] [error] cannot be applied to (Boolean, org.apache.kafka.common.serialization.StringSerializer, org.apache.kafka.common.serialization.StringSerializer) [error] val producer = new MockProducer[String, String](true, new StringSerializer, new StringSerializer) [error] ^ [error] /home/runner/work/pekko-connectors-kafka/pekko-connectors-kafka/tests/src/test/scala/org/apache/pekko/kafka/internal/ProducerSpec.scala:161:26: overloaded method constructor MockProducer with alternatives: [error] ()org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: Boolean,x$2: org.apache.kafka.clients.producer.Partitioner,x$3: org.apache.kafka.common.serialization.Serializer[String],x$4: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] <and> [error] (x$1: org.apache.kafka.common.Cluster,x$2: Boolean,x$3: org.apache.kafka.clients.producer.Partitioner,x$4: org.apache.kafka.common.serialization.Serializer[String],x$5: org.apache.kafka.common.serialization.Serializer[String])org.apache.kafka.clients.producer.MockProducer[String,String] [error] cannot be applied to (Boolean, org.apache.kafka.common.serialization.StringSerializer, org.apache.kafka.common.serialization.StringSerializer) [error] val mockProducer = new MockProducer[String, String](true, new StringSerializer, new StringSerializer) [error] ^ [error] 18 errors found ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: notifications-unsubscr...@pekko.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: notifications-unsubscr...@pekko.apache.org For additional commands, e-mail: notifications-h...@pekko.apache.org
