masesgroup#4: improved KafkaAdminClient

src/KafkaBridge/BridgedClasses/Clients/Admin/DeleteTopicsOptions.cs

@@ -0,0 +1,42 @@
+/*
+*  Copyright 2021 MASES s.r.l.
+*
+*  Licensed under the Apache License, Version 2.0 (the "License");
+*  you may not use this file except in compliance with the License.
+*  You may obtain a copy of the License at
+*
+*  http://www.apache.org/licenses/LICENSE-2.0
+*
+*  Unless required by applicable law or agreed to in writing, software
+*  distributed under the License is distributed on an "AS IS" BASIS,
+*  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+*  See the License for the specific language governing permissions and
+*  limitations under the License.
+*
+*  Refer to LICENSE for more information.
+*/
+
+namespace MASES.KafkaBridge.Clients.Admin
+{
+    public class DeleteTopicsOptions : JCOBridge.C2JBridge.JVMBridgeBase<DeleteTopicsOptions>
+    {
+        public override string ClassName => "org.apache.kafka.clients.admin.DeleteTopicsOptions";
+
+        public DeleteTopicsOptions timeoutMs(int timeoutMs)
+        {
+            IExecute("timeoutMs", timeoutMs);
+            return this;
+        }
+
+        public DeleteTopicsOptions retryOnQuotaViolation(bool validateOnly)
+        {
+            IExecute("retryOnQuotaViolation", validateOnly);
+            return this;
+        }
+
+        public bool shouldRetryOnQuotaViolation()
+        {
+            return (bool)IExecute("shouldRetryOnQuotaViolation");
+        }
+    }
+}

src/KafkaBridge/BridgedClasses/Clients/Admin/DeleteTopicsResult.cs

@@ -0,0 +1,25 @@
+/*
+*  Copyright 2021 MASES s.r.l.
+*
+*  Licensed under the Apache License, Version 2.0 (the "License");
+*  you may not use this file except in compliance with the License.
+*  You may obtain a copy of the License at
+*
+*  http://www.apache.org/licenses/LICENSE-2.0
+*
+*  Unless required by applicable law or agreed to in writing, software
+*  distributed under the License is distributed on an "AS IS" BASIS,
+*  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+*  See the License for the specific language governing permissions and
+*  limitations under the License.
+*
+*  Refer to LICENSE for more information.
+*/
+
+namespace MASES.KafkaBridge.Clients.Admin
+{
+    public class DeleteTopicsResult : JCOBridge.C2JBridge.JVMBridgeBase<DeleteTopicsResult>
+    {
+        public override string ClassName => "org.apache.kafka.clients.admin.DeleteTopicsResult";
+    }
+}

src/KafkaBridge/BridgedClasses/Clients/Admin/DescribeClusterResult.cs

@@ -0,0 +1,12 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace MASES.KafkaBridge.BridgedClasses.Clients.Admin
+{
+    class DescribeClusterResult
+    {
+    }
+}

src/KafkaBridge/BridgedClasses/Clients/Admin/DescribeTopicsResult.cs

@@ -0,0 +1,12 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace MASES.KafkaBridge.BridgedClasses.Clients.Admin
+{
+    class DescribeTopicsResult
+    {
+    }
+}

src/KafkaBridge/BridgedClasses/Clients/Admin/KafkaAdminClient.cs

@@ -38,6 +38,11 @@ public CreateTopicsResult CreateTopics(Collection<NewTopic> newTopics, CreateTop
         {
             return IExecute<CreateTopicsResult>("createTopics", newTopics.Instance, options.Instance);
         }
+
+        public CreateTopicsResult DeleteTopics(Collection<NewTopic> newTopics)
+        {
+            return IExecute<CreateTopicsResult>("deleteTopics", newTopics.Instance);
+        }
     }
 }
 

src/KafkaBridge/BridgedClasses/Clients/Admin/ListTopicsResult.cs

@@ -0,0 +1,12 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace MASES.KafkaBridge.BridgedClasses.Clients.Admin
+{
+    class ListTopicsResult
+    {
+    }
+}