From 7782ca8107ceb982f5633a4297f4011c71bc1898 Mon Sep 17 00:00:00 2001 From: PradnyaC11 Date: Tue, 27 Aug 2024 09:38:07 -0700 Subject: [PATCH 1/2] [CITE-163] Added kafka topic for importing collections --- .../java/edu/asu/diging/citesphere/messages/KafkaTopics.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/citesphere-messages/src/main/java/edu/asu/diging/citesphere/messages/KafkaTopics.java b/citesphere-messages/src/main/java/edu/asu/diging/citesphere/messages/KafkaTopics.java index dd150a0..2cfba28 100644 --- a/citesphere-messages/src/main/java/edu/asu/diging/citesphere/messages/KafkaTopics.java +++ b/citesphere-messages/src/main/java/edu/asu/diging/citesphere/messages/KafkaTopics.java @@ -7,4 +7,6 @@ public interface KafkaTopics { public final static String REFERENCES_EXPORT_TOPIC = "_citesphere_export_references_topic"; public final static String REFERENCES_EXPORT_DONE_TOPIC = "_citesphere_export_references_done_topic"; + + public final static String COLLECTION_IMPORT_TOPIC = "_citesphere_import_collections_topic"; } From c010d420ec93d7a4769c54085825e08c88639489 Mon Sep 17 00:00:00 2001 From: PradnyaC11 Date: Fri, 2 May 2025 15:20:32 -0700 Subject: [PATCH 2/2] [CITE-163] Addressed PR comment --- .../edu/asu/diging/citesphere/messages/KafkaTopics.java | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/citesphere-messages/src/main/java/edu/asu/diging/citesphere/messages/KafkaTopics.java b/citesphere-messages/src/main/java/edu/asu/diging/citesphere/messages/KafkaTopics.java index 7f7650e..341a8ef 100644 --- a/citesphere-messages/src/main/java/edu/asu/diging/citesphere/messages/KafkaTopics.java +++ b/citesphere-messages/src/main/java/edu/asu/diging/citesphere/messages/KafkaTopics.java @@ -8,6 +8,15 @@ public interface KafkaTopics { public final static String REFERENCES_EXPORT_TOPIC = "_citesphere_export_references_topic"; public final static String REFERENCES_EXPORT_DONE_TOPIC = "_citesphere_export_references_done_topic"; + /** + * The name of the Kafka topic used for collection import events. Messages published to this topic + * will trigger import processing of citations to a collection/group from BibTex File, which + * is exported from Zotero. + */ public final static String COLLECTION_IMPORT_TOPIC = "_citesphere_import_collections_topic"; + /** + * The name of the Kafka topic used for crossref citation import events. Messages published to this topic + * will trigger import processing of citations to a group from crossref. + */ public final static String REFERENCES_IMPORT_CROSSREF_TOPIC = "_citesphere_import_crossref_topic"; }