Merge pull request #4839 from dilanSachi/update-kafka-bbes

[master] Update kafka BBEs
ballerina-platform · Aug 25, 2023 · a414c9f · a414c9f
2 parents a9ab2ef + 63848e0
commit a414c9f
Show file tree

Hide file tree

Showing 13 changed files with 31 additions and 30 deletions.
diff --git a/examples/kafka-consumer-constraint-validation/kafka_consumer_constraint_validation.bal b/examples/kafka-consumer-constraint-validation/kafka_consumer_constraint_validation.bal
@@ -2,7 +2,7 @@ import ballerina/constraint;
 import ballerinax/kafka;
 import ballerina/io;
 
-public type Order record {
+type Order record {
     int orderId;
     // Add a constraint to only allow string values of length between 30 and 1.
     @constraint:String {maxLength: 30, minLength: 1}
@@ -19,7 +19,7 @@ public function main() returns error? {
 
     while true {
         Order[] orders = check orderConsumer->pollPayload(15);
-        check from Order 'order in orders
+        from Order 'order in orders
             where 'order.isValid
             do {
                 io:println(string `Received valid order for ${'order.productName}`);

diff --git a/...fka-consumer-consumer-record-data-binding/kafka_consumer_consumer_record_data_binding.bal b/...fka-consumer-consumer-record-data-binding/kafka_consumer_consumer_record_data_binding.bal
@@ -1,15 +1,15 @@
 import ballerinax/kafka;
 import ballerina/io;
 
-public type Order readonly & record {
+type Order readonly & record {
     int orderId;
     string productName;
     decimal price;
     boolean isValid;
 };
 
 // Create a subtype of `kafka:AnydataConsumerRecord`.
-public type OrderConsumerRecord record {|
+type OrderConsumerRecord record {|
     *kafka:AnydataConsumerRecord;
     Order value;
 |};
@@ -23,7 +23,7 @@ public function main() returns error? {
     while true {
         // Polls the consumer for order records.
         OrderConsumerRecord[] records = check orderConsumer->poll(15);
-        check from OrderConsumerRecord orderRecord in records
+        from OrderConsumerRecord orderRecord in records
             where orderRecord.value.isValid
             do {
                 io:println(string `Received valid order for ${orderRecord.value.productName}`);

diff --git a/examples/kafka-consumer-payload-data-binding/kafka_consumer_payload_data_binding.bal b/examples/kafka-consumer-payload-data-binding/kafka_consumer_payload_data_binding.bal
@@ -1,7 +1,7 @@
 import ballerinax/kafka;
 import ballerina/io;
 
-public type Order readonly & record {
+type Order readonly & record {
     int orderId;
     string productName;
     decimal price;
@@ -17,7 +17,7 @@ public function main() returns error? {
     while true {
         // Polls the consumer for payload.
         Order[] orders = check orderConsumer->pollPayload(15);
-        check from Order 'order in orders
+        from Order 'order in orders
             where 'order.isValid
             do {
                 io:println(string `Received valid order for ${'order.productName}`);

diff --git a/examples/kafka-consumer-sasl/kafka_consumer_sasl.bal b/examples/kafka-consumer-sasl/kafka_consumer_sasl.bal
@@ -1,7 +1,7 @@
 import ballerinax/kafka;
 import ballerina/io;
 
-public type Order readonly & record {
+type Order readonly & record {
     int orderId;
     string productName;
     decimal price;
@@ -27,7 +27,7 @@ public function main() returns error? {
     // Polls the consumer for payload.
     Order[] orders = check orderConsumer->pollPayload(1);
 
-    check from Order 'order in orders
+    from Order 'order in orders
         where 'order.isValid
         do {
             io:println(string `Received valid order for ${'order.productName}`);

diff --git a/examples/kafka-consumer-ssl/kafka_consumer_ssl.bal b/examples/kafka-consumer-ssl/kafka_consumer_ssl.bal
@@ -1,7 +1,7 @@
 import ballerinax/kafka;
 import ballerina/io;
 
-public type Order readonly & record {
+type Order readonly & record {
     int orderId;
     string productName;
     decimal price;
@@ -27,7 +27,7 @@ public function main() returns error? {
     // Polls the consumer for payload.
     Order[] orders = check orderConsumer->pollPayload(1);
 
-    check from Order 'order in orders
+    from Order 'order in orders
         where 'order.isValid
         do {
             io:println(string `Received valid order for ${'order.productName}`);

diff --git a/examples/kafka-producer-produce-message/kafka_producer_produce_message.bal b/examples/kafka-producer-produce-message/kafka_producer_produce_message.bal
@@ -1,7 +1,7 @@
 import ballerinax/kafka;
 import ballerina/http;
 
-public type Order readonly & record {
+type Order readonly & record {
     int orderId;
     string productName;
     decimal price;
@@ -15,7 +15,7 @@ service / on new http:Listener(9090) {
         self.orderProducer = check new (kafka:DEFAULT_URL);
     }
 
-    resource function post orders(@http:Payload anydata newOrder) returns http:Accepted|error {
+    resource function post orders(Order newOrder) returns http:Accepted|error {
         check self.orderProducer->send({
             topic: "order-topic",
             value: newOrder

diff --git a/examples/kafka-producer-sasl/kafka_producer_sasl.bal b/examples/kafka-producer-sasl/kafka_producer_sasl.bal
@@ -1,7 +1,7 @@
 import ballerina/http;
 import ballerinax/kafka;
 
-public type Order readonly & record {
+type Order readonly & record {
     int orderId;
     string productName;
     decimal price;

diff --git a/examples/kafka-producer-ssl/kafka_producer_ssl.bal b/examples/kafka-producer-ssl/kafka_producer_ssl.bal
@@ -1,7 +1,7 @@
 import ballerina/http;
 import ballerinax/kafka;
 
-public type Order readonly & record {
+type Order readonly & record {
     int orderId;
     string productName;
     decimal price;

diff --git a/examples/kafka-service-constraint-validation/kafka_service_constraint_validation.bal b/examples/kafka-service-constraint-validation/kafka_service_constraint_validation.bal
@@ -2,7 +2,7 @@ import ballerina/constraint;
 import ballerinax/kafka;
 import ballerina/log;
 
-public type Order record {
+type Order record {
     int orderId;
     // Add a constraint to only allow string values of length between 30 and 1.
     @constraint:String {maxLength: 30, minLength: 1}
@@ -18,8 +18,8 @@ listener kafka:Listener orderListener = new (kafka:DEFAULT_URL, {
 
 service on orderListener {
 
-    remote function onConsumerRecord(Order[] orders) returns error? {
-        check from Order 'order in orders
+    remote function onConsumerRecord(Order[] orders) {
+        from Order 'order in orders
             where 'order.isValid
             do {
                 log:printInfo(string `Received valid order for ${'order.productName}`);

diff --git a/examples/kafka-service-consume-message/kafka_service_consume_message.bal b/examples/kafka-service-consume-message/kafka_service_consume_message.bal
@@ -1,7 +1,7 @@
 import ballerinax/kafka;
 import ballerina/log;
 
-public type Order readonly & record {
+type Order readonly & record {
     int orderId;
     string productName;
     decimal price;
@@ -15,9 +15,9 @@ listener kafka:Listener orderListener = new (kafka:DEFAULT_URL, {
 
 service on orderListener {
 
-    remote function onConsumerRecord(Order[] orders) returns error? {
+    remote function onConsumerRecord(Order[] orders) {
         // The set of orders received by the service are processed one by one.
-        check from Order 'order in orders
+        from Order 'order in orders
             where 'order.isValid
             do {
                 log:printInfo(string `Received valid order for ${'order.productName}`);

diff --git a/examples/kafka-service-error-handling/kafka_service_error_handling.bal b/examples/kafka-service-error-handling/kafka_service_error_handling.bal
@@ -1,7 +1,7 @@
 import ballerinax/kafka;
 import ballerina/log;
 
-public type Order readonly & record {
+type Order readonly & record {
     int orderId;
     string productName;
     decimal price;
@@ -17,9 +17,9 @@ listener kafka:Listener orderListener = new (kafka:DEFAULT_URL, {
 
 service on orderListener {
 
-    remote function onConsumerRecord(Order[] orders) returns error? {
+    remote function onConsumerRecord(Order[] orders) {
         // The set of orders received by the service are processed one by one.
-        check from Order 'order in orders
+        from Order 'order in orders
             where 'order.isValid
             do {
                 log:printInfo(string `Received valid order for ${'order.productName}`);
@@ -42,4 +42,5 @@ service on orderListener {
         } else {
             log:printError("An error occured", 'error);
         }
+    }
 }
diff --git a/examples/kafka-service-sasl/kafka_service_sasl.bal b/examples/kafka-service-sasl/kafka_service_sasl.bal
@@ -1,7 +1,7 @@
 import ballerinax/kafka;
 import ballerina/log;
 
-public type Order readonly & record {
+type Order readonly & record {
     int orderId;
     string productName;
     decimal price;
@@ -26,8 +26,8 @@ listener kafka:Listener orderListener = new ("localhost:9093", {
 
 service on orderListener {
 
-    remote function onConsumerRecord(Order[] orders) returns error? {
-        check from Order 'order in orders
+    remote function onConsumerRecord(Order[] orders) {
+        from Order 'order in orders
             where 'order.isValid
             do {
                 log:printInfo(string `Received valid order for ${'order.productName}`);

diff --git a/examples/kafka-service-ssl/kafka_service_ssl.bal b/examples/kafka-service-ssl/kafka_service_ssl.bal
@@ -1,7 +1,7 @@
 import ballerinax/kafka;
 import ballerina/log;
 
-public type Order readonly & record {
+type Order readonly & record {
     int orderId;
     string productName;
     decimal price;
@@ -25,8 +25,8 @@ listener kafka:Listener orderListener = new ("localhost:9094", {
 
 service on orderListener {
 
-    remote function onConsumerRecord(Order[] orders) returns error? {
-        check from Order 'order in orders
+    remote function onConsumerRecord(Order[] orders) {
+        from Order 'order in orders
             where 'order.isValid
             do {
                 log:printInfo(string `Received valid order for ${'order.productName}`);