Update Pulsar version to match our current StreamNative clusters

Author: jdimeo

pulsar/pom.xml

@@ -14,11 +14,11 @@
 
 	<properties>
 		<!-- Keep in sync with the version in our cloud StreamNative -->
-		<pulsar.version>3.0.4.6</pulsar.version>
-		<log4j.version>2.20.0</log4j.version>
+		<pulsar.version>3.3.3.3</pulsar.version>
+		<log4j.version>2.23.1</log4j.version>
 
 		<!-- Need the BOM to reconcile version conflicts -->
-		<grpc.version>1.55.3</grpc.version>
+		<grpc.version>1.56.1</grpc.version>
 	</properties>
 
 	<dependencyManagement>

pulsar/src/main/java/com/compassion/commons/pulsar/mock/MockContext.java

@@ -85,4 +85,5 @@ public MockContext putSecret(String secretName, String secret) {
 	@Override public void deleteState(String key) { /* No impl */ }
 	@Override public PulsarAdmin getPulsarAdmin() { return null; }
 	@Override public <X> FunctionRecordBuilder<X> newOutputRecordBuilder(Schema<X> schema) { return null; }
+	@Override public void fatal(Throwable t) { log.error("Pulsar error", t); }
 }