Skip to content

Commit

Permalink
Java 8 compatibility fix
Browse files Browse the repository at this point in the history
  • Loading branch information
arkadius committed Sep 22, 2021
1 parent cc14573 commit 288471c
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ private[confluent] class ConfluentAvroMessageFormatter(schemaRegistryClient: Sch
val writer = createDatumWriter(record, schema, useSchemaReflection = false)
writer.write(record, encoder)
encoder.flush()
val str = bos.toString(StandardCharsets.UTF_8)
val str = bos.toString(StandardCharsets.UTF_8.toString)
// assume the output of encoder is correct or throw Exception trying
io.circe.parser.parse(str).right.get
} catch {
Expand Down

0 comments on commit 288471c

Please sign in to comment.