Skip to content

Commit

Permalink
Fix deprecated error
Browse files Browse the repository at this point in the history
  • Loading branch information
@svroonland
svroonland committed Dec 22, 2024
1 parent 1c63817 commit 1d54bcc
Showing 1 changed file with 11 additions and 11 deletions.
22 changes: 11 additions & 11 deletions zio-kafka-test/src/test/scala/zio/kafka/ProducerSpec.scala
View file
Original file line number Diff line number Diff line change
Expand Up @@ -192,7 +192,7 @@ object ProducerSpec extends ZIOSpecDefaultSlf4j with KafkaRandom {
record1 <- ZIO.scoped {
withConsumer(Topics(Set(topic1)), settings).flatMap { consumer =>
for {
messages <- consumer.take.flatMap(_.done).mapError(_.getOrElse(new NoSuchElementException))
messages <- consumer.take.flatMap(_.exit).mapError(_.getOrElse(new NoSuchElementException))
record = messages
.filter(rec => rec.record.key == key1 && rec.record.value == value1)
} yield record
Expand All @@ -201,7 +201,7 @@ object ProducerSpec extends ZIOSpecDefaultSlf4j with KafkaRandom {
record2 <- ZIO.scoped {
withConsumer(Topics(Set(topic2)), settings).flatMap { consumer =>
for {
messages <- consumer.take.flatMap(_.done).mapError(_.getOrElse(new NoSuchElementException))
messages <- consumer.take.flatMap(_.exit).mapError(_.getOrElse(new NoSuchElementException))
record = messages.filter(rec => rec.record.key == key2 && rec.record.value == value2)
} yield record
}
Expand Down Expand Up @@ -244,7 +244,7 @@ object ProducerSpec extends ZIOSpecDefaultSlf4j with KafkaRandom {
settings <- consumerSettings(client, Some(group))
recordsConsumed <- ZIO.scoped {
withConsumer(Topics(Set(standardTopic)), settings).flatMap { consumer =>
consumer.take.flatMap(_.done).mapError(_.getOrElse(new NoSuchElementException))
consumer.take.flatMap(_.exit).mapError(_.getOrElse(new NoSuchElementException))
}
}
} yield assertTrue(
Expand Down Expand Up @@ -294,7 +294,7 @@ object ProducerSpec extends ZIOSpecDefaultSlf4j with KafkaRandom {
withConsumerInt(Topics(Set(topic)), settings).flatMap { consumer =>
for {
messages <- consumer.take
.flatMap(_.done)
.flatMap(_.exit)
.mapError(_.getOrElse(new NoSuchElementException))
record = messages.filter(rec => rec.record.key == "bob")
} yield record
Expand Down Expand Up @@ -334,7 +334,7 @@ object ProducerSpec extends ZIOSpecDefaultSlf4j with KafkaRandom {
withConsumerInt(Topics(Set(topic)), settings).flatMap { consumer =>
for {
messages <- consumer.take
.flatMap(_.done)
.flatMap(_.exit)
.mapError(_.getOrElse(new NoSuchElementException))
record = messages.filter(rec => rec.record.key == "bob")
} yield record
Expand Down Expand Up @@ -369,7 +369,7 @@ object ProducerSpec extends ZIOSpecDefaultSlf4j with KafkaRandom {
withConsumerInt(Topics(Set(topic)), settings).flatMap { consumer =>
for {
messages <- consumer.take
.flatMap(_.done)
.flatMap(_.exit)
.mapError(_.getOrElse(new NoSuchElementException))
} yield messages
}
Expand Down Expand Up @@ -422,7 +422,7 @@ object ProducerSpec extends ZIOSpecDefaultSlf4j with KafkaRandom {
withConsumerInt(Topics(Set(topic)), settings).flatMap { consumer =>
for {
messages <- consumer.take
.flatMap(_.done)
.flatMap(_.exit)
.mapError(_.getOrElse(new NoSuchElementException))
record = messages.filter(rec => rec.record.key == "no one")
} yield record
Expand Down Expand Up @@ -463,7 +463,7 @@ object ProducerSpec extends ZIOSpecDefaultSlf4j with KafkaRandom {
withConsumerInt(Topics(Set(topic)), settings).flatMap { consumer =>
for {
messages <- consumer.take
.flatMap(_.done)
.flatMap(_.exit)
.mapError(_.getOrElse(new NoSuchElementException))
record = messages.filter(rec => rec.record.key == "no one")
} yield record
Expand Down Expand Up @@ -509,7 +509,7 @@ object ProducerSpec extends ZIOSpecDefaultSlf4j with KafkaRandom {
withConsumerInt(Topics(Set(topic)), settings).flatMap { consumer =>
for {
messages <- consumer.take
.flatMap(_.done)
.flatMap(_.exit)
.mapError(_.getOrElse(new NoSuchElementException))
record = messages.filter(rec => rec.record.key == "no one")
} yield record
Expand Down Expand Up @@ -540,7 +540,7 @@ object ProducerSpec extends ZIOSpecDefaultSlf4j with KafkaRandom {
.flatMap { q =>
val readAliceAccount = for {
messages <- q.take
.flatMap(_.done)
.flatMap(_.exit)
.mapError(_.getOrElse(new NoSuchElementException))
} yield messages.head
for {
Expand Down Expand Up @@ -587,7 +587,7 @@ object ProducerSpec extends ZIOSpecDefaultSlf4j with KafkaRandom {
.flatMap { q =>
val readAliceAccount = for {
messages <- q.take
.flatMap(_.done)
.flatMap(_.exit)
.mapError(_.getOrElse(new NoSuchElementException))
} yield messages.head
for {
Expand Down

0 comments on commit 1d54bcc

Please sign in to comment.