diff --git a/radar-commons/src/main/java/org/radarcns/topic/AvroTopic.java b/radar-commons/src/main/java/org/radarcns/topic/AvroTopic.java
index 6bf049db..54933ff0 100644
--- a/radar-commons/src/main/java/org/radarcns/topic/AvroTopic.java
+++ b/radar-commons/src/main/java/org/radarcns/topic/AvroTopic.java
@@ -147,12 +147,11 @@ public boolean equals(Object o) {
 
         AvroTopic topic = (AvroTopic) o;
 
-        return keyClass == topic.getKeyClass() && valueClass == topic.getValueClass()
-            && keySchema.equals(topic.getKeySchema()) && valueSchema.equals(topic.getValueSchema());
+        return keyClass == topic.getKeyClass() && valueClass == topic.getValueClass();
     }
 
     @Override
     public int hashCode() {
-        return Objects.hash(getName(), keyClass, valueClass, keySchema, valueSchema);
+        return Objects.hash(getName(), keyClass, valueClass);
     }
 }