in java/avro-converter/src/main/java/com/microsoft/azure/schemaregistry/kafka/connect/avro/AvroConverterUtils.java [1114:1126]
private boolean isMapEntry(final org.apache.avro.Schema mapElementSchema) {
if (!mapElementSchema.getType().equals(org.apache.avro.Schema.Type.RECORD)) {
return false;
}
if (NAMESPACE.equals(mapElementSchema.getNamespace())
&& MAP_ENTRY_TYPE_NAME.equals(mapElementSchema.getName())) {
return true;
}
if (Objects.equals(mapElementSchema.getProp(CONNECT_INTERNAL_TYPE_NAME), MAP_ENTRY_TYPE_NAME)) {
return true;
}
return false;
}