Kafka observability edits

Convex-Dev · Oct 27, 2023 · 6628fc3 · 6628fc3
1 parent 709ffed
commit 6628fc3
Showing 1 changed file with 6 additions and 5 deletions.
diff --git a/convex-observer/src/main/java/convex/observer/StrimziKafka.java b/convex-observer/src/main/java/convex/observer/StrimziKafka.java
@@ -64,8 +64,9 @@ public synchronized static StrimziKafka get(Server server) {
 	public StrimziKafka(Server server) {
 		super(server.getStore());
 		// TODO: need to be config params etc.
-		this.topic="test";
-		this.url="https://kfk.walledchannel.net:8010/topics/";
+		this.topic="transactions";
+		// this.url="https://kfk.walledchannel.net:9092/topics/";
+		this.url="https://kfk.walledchannel.net/topics/";
 		this.peerKey=server.getPeerKey().toString();
 	}
 
@@ -187,17 +188,17 @@ public void loop() throws InterruptedException {
 		httpasyncclient.execute(post, new FutureCallback<SimpleHttpResponse>() {
 			@Override
 			public void completed(SimpleHttpResponse result) {
-				//System.err.println(result);
+				// System.err.println(result);
 			}
 
 			@Override
 			public void failed(Exception ex) {
-				System.err.println(ex);
+				// System.err.println(ex);
 			}
 
 			@Override
 			public void cancelled() {
-				System.err.println("Observation Cancelled");
+				// System.err.println("Observation Cancelled");
 			};
 		});
 	}