Add Producer config parameters in config.properties:

- blockIfQueueFull
- maxPendingMessages
- batchingMaxMessages

driver-pulsar/src/main/resources/activities/bindingtest.yaml

@@ -1,5 +1,6 @@
 #
 # Results:
+# - 10 tenants
 # - 2 namespaces per tanant
 # - 5 topics per namespace
 #------------------------------------------------------
@@ -23,12 +24,13 @@
 #tenant=tenant_1 namespace=default_1 core_topic_name=t2
 #tenant=tenant_1 namespace=default_1 core_topic_name=t3
 #tenant=tenant_1 namespace=default_1 core_topic_name=t4
+# ... ...
 
 bindings:
   # message key and value
   #mykey: NumberNameToString()
   #myvalue: AlphaNumericString(20)
   # Admin API - create tenant, namespace, and topic
-  tenant: Mod(1000); Div(10L); ToString(); Prefix("tenant_")
+  tenant: Mod(100); Div(10L); ToString(); Prefix("tenant_")
   namespace: Mod(10); Div(5L); ToString(); Prefix("default_")
   core_topic_name: Mod(5); ToString(); Prefix("t")

driver-pulsar/src/main/resources/activities/config.properties

@@ -8,13 +8,17 @@
 # TODO: as a starting point, only supports the following types
 #       1) primitive types, including bytearray (byte[]) which is default, for messages without schema
 #       2) Avro for messages with schema
-schema.type=avro
-schema.definition=file://<file/path/to/iot-example.avsc>
+schema.type=
+schema.definition=
 
 
 ### Pulsar client related configurations - client.xxx
 # http://pulsar.apache.org/docs/en/client-libraries-java/#client
 client.connectionTimeoutMs=5000
+client.authPluginClassName=org.apache.pulsar.client.impl.auth.AuthenticationToken
+# Cluster admin
+client.authParams=
+client.tlsAllowInsecureConnection=true
 
 
 ### Producer related configurations (global) - producer.xxx
@@ -22,6 +26,9 @@ client.connectionTimeoutMs=5000
 producer.producerName=
 producer.topicName=
 producer.sendTimeoutMs=
+producer.blockIfQueueFull=true
+producer.maxPendingMessages=5000
+producer.batchingMaxMessages=5000
 
 
 ### Consumer related configurations (global) - consumer.xxx

driver-pulsar/src/main/resources/activities/pulsar_client_kv.yaml

@@ -1,7 +1,7 @@
 bindings:
   # message key and value
-  mykey: NumberNameToString()
-  myvalue: AlphaNumericString(20)
+  mykey:
+  myvalue: NumberNameToString()  #AlphaNumericString(20)
   tenant: Mod(10000); Div(10L); ToString(); Prefix("tnt")
   namespace: Mod(10); Div(5L); ToString(); Prefix("ns")
   core_topic_name: Mod(5); ToString(); Prefix("t")
@@ -39,7 +39,7 @@ blocks:
       - name: s1
         optype: msg-send
         # producer_name: {producer_name}
-        msg_key: "{mykey}"
+        msg_key:
         msg_value: "{myvalue}"
 
   - name: consumer-block