I am getting this CodeConfiguration exception
logger: reactor.core.publisher.Operators
message: Operator called default onErrorDropped
thread: Thread-24
throwable: { [[-]](https://splunk-ist-test.rno.apple.com/en-US/app/search/search?earliest=-24h%40h&latest=now&q=search%20index%3Deform_*core%20kafka&display.page.search.mode=verbose&dispatch.sample_ratio=1&sid=1715627677.63804_8AA9301C-E7E5-45F4-9380-6FDA919BA5FF#)
cause: { [[-]](https://splunk-ist-test.rno.apple.com/en-US/app/search/search?earliest=-24h%40h&latest=now&q=search%20index%3Deform_*core%20kafka&display.page.search.mode=verbose&dispatch.sample_ratio=1&sid=1715627677.63804_8AA9301C-E7E5-45F4-9380-6FDA919BA5FF#)
class: org.bson.codecs.configuration.CodecConfigurationException
msg: Can't find a codec for class com.bibpm.notificationmonitor.model.Inboundnotifq.
stack: [ [[-]](https://splunk-ist-test.rno.apple.com/en-US/app/search/search?earliest=-24h%40h&latest=now&q=search%20index%3Deform_*core%20kafka&display.page.search.mode=verbose&dispatch.sample_ratio=1&sid=1715627677.63804_8AA9301C-E7E5-45F4-9380-6FDA919BA5FF#)
org.bson.internal.CodecCache.lambda$getOrThrow$1(CodecCache.java:52)
java.util.Optional.orElseThrow(Optional.java:403)
org.bson.internal.CodecCache.getOrThrow(CodecCache.java:51)
org.bson.internal.OverridableUuidRepresentationCodecRegistry.get(OverridableUuidRepresentationCodecRegistry.java:72)
org.bson.internal.OverridableUuidRepresentationCodecRegistry.get(OverridableUuidRepresentationCodecRegistry.java:48)
com.mongodb.internal.operation.Operations.getCodec(Operations.java:613)
com.mongodb.internal.operation.Operations.bulkWrite(Operations.java:449)
com.mongodb.internal.operation.Operations.insertOne(Operations.java:375)
com.mongodb.reactivestreams.client.internal.MongoOperationPublisher.lambda$insertOne$7(MongoOperationPublisher.java:325)
com.mongodb.reactivestreams.client.internal.MongoOperationPublisher.createWriteOperationMono(MongoOperationPublisher.java:488)
com.mongodb.reactivestreams.client.internal.MongoOperationPublisher.createSingleWriteRequestMono(MongoOperationPublisher.java:496)
com.mongodb.reactivestreams.client.internal.MongoOperationPublisher.insertOne(MongoOperationPublisher.java:325)
com.mongodb.reactivestreams.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:363)
com.mongodb.reactivestreams.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:358)
``
type or paste code here
Here is th POJO
@Getter
@Setter
@Named
@JsonInclude(JsonInclude.Include.NON_NULL)
@ToString
public class Inboundnotifq implements Serializable {
@BsonProperty("_id")
@BsonIgnore
@JsonIgnore
private ObjectId id;
private Map<String, Object> data;
@BsonProperty("processed")
private Boolean processed;
@BsonProperty("failed")
private Boolean failed;
@BsonProperty("receivedTime")
private Date receivedTime;
@BsonProperty("clientAppId")
private String clientAppId;
@BsonProperty("submissionId")
private String submissionId;
@BsonProperty("notificationId")
private String notificationId;
@BsonProperty("created")
private Date created;
@BsonProperty("updated")
private Date updated;
@BsonProperty("eventId")
private String eventId;
@Override
public boolean equals(final Object o) {
if (this == o) {
return true;
}
if (o == null || getClass() != o.getClass()) {
return false;
}
Inboundnotifq that = (Inboundnotifq) o;
return Objects.equals(getEventId(), that.getEventId());
}
@Override
public int hashCode() {
return Objects.hash(getEventId());
}
}