Fix JNI name of nested classes (#72)

masesgroup · May 20, 2022 · d852182 · d852182
1 parent 7ed1ad8
commit d852182
Show file tree

Hide file tree

Showing 9 changed files with 16 additions and 16 deletions.
diff --git a/src/net/KNet/ClientSide/BridgedClasses/Clients/Admin/ConfigEntry.cs b/src/net/KNet/ClientSide/BridgedClasses/Clients/Admin/ConfigEntry.cs
@@ -75,7 +75,7 @@ public enum ConfigSource
 
         public class ConfigSynonym : JCOBridge.C2JBridge.JVMBridgeBase<Config>
         {
-            public override string ClassName => "org.apache.kafka.clients.admin.ConfigEntry.ConfigSynonym";
+            public override string ClassName => "org.apache.kafka.clients.admin.ConfigEntry$ConfigSynonym";
 
             public string Name => IExecute<string>("name");
 

diff --git a/src/net/KNet/ClientSide/BridgedClasses/Clients/Admin/DeleteAclsResult.cs b/src/net/KNet/ClientSide/BridgedClasses/Clients/Admin/DeleteAclsResult.cs
@@ -33,14 +33,14 @@ public class DeleteAclsResult : JCOBridge.C2JBridge.JVMBridgeBase<DeleteAclsResu
 
         public class FilterResults : JCOBridge.C2JBridge.JVMBridgeBase<FilterResults>
         {
-            public override string ClassName => "org.apache.kafka.clients.admin.DeleteAclsResult.FilterResults";
+            public override string ClassName => "org.apache.kafka.clients.admin.DeleteAclsResult$FilterResults";
 
             public List<FilterResult> Values => IExecute<List<FilterResult>>("values");
         }
 
         public class FilterResult : JCOBridge.C2JBridge.JVMBridgeBase<FilterResult>
         {
-            public override string ClassName => "org.apache.kafka.clients.admin.DeleteAclsResult.FilterResult";
+            public override string ClassName => "org.apache.kafka.clients.admin.DeleteAclsResult$FilterResult";
 
             public AclBinding Binding => IExecute<AclBinding>("binding");
 

diff --git a/src/net/KNet/ClientSide/BridgedClasses/Clients/Admin/DescribeProducersResult.cs b/src/net/KNet/ClientSide/BridgedClasses/Clients/Admin/DescribeProducersResult.cs
@@ -35,7 +35,7 @@ public KafkaFuture<PartitionProducerState> PartitionResult(TopicPartition partit
 
         public class PartitionProducerState : JCOBridge.C2JBridge.JVMBridgeBase<DescribeProducersResult>
         {
-            public override string ClassName => "org.apache.kafka.clients.admin.DescribeProducersResult.PartitionProducerState";
+            public override string ClassName => "org.apache.kafka.clients.admin.DescribeProducersResult$PartitionProducerState";
 
             public PartitionProducerState(List<ProducerState> activeProducers)
                 :base(activeProducers)

diff --git a/src/net/KNet/ClientSide/BridgedClasses/Clients/Admin/DescribeReplicaLogDirsResult.cs b/src/net/KNet/ClientSide/BridgedClasses/Clients/Admin/DescribeReplicaLogDirsResult.cs
@@ -31,7 +31,7 @@ public class DescribeReplicaLogDirsResult : JCOBridge.C2JBridge.JVMBridgeBase<De
 
         public class ReplicaLogDirInfo : JCOBridge.C2JBridge.JVMBridgeBase<DescribeReplicaLogDirsResult>
         {
-            public override string ClassName => "org.apache.kafka.clients.admin.DescribeReplicaLogDirsResult.ReplicaLogDirInfo";
+            public override string ClassName => "org.apache.kafka.clients.admin.DescribeReplicaLogDirsResult$ReplicaLogDirInfo";
 
             public string GetCurrentReplicaLogDir => IExecute<string>("getCurrentReplicaLogDir");
 

diff --git a/src/net/KNet/ClientSide/BridgedClasses/Clients/Admin/ListOffsetsResult.cs b/src/net/KNet/ClientSide/BridgedClasses/Clients/Admin/ListOffsetsResult.cs
@@ -47,7 +47,7 @@ public KafkaFuture<ListOffsetsResultInfo> PartitionResult(TopicPartition partiti
 
         public class ListOffsetsResultInfo : JCOBridge.C2JBridge.JVMBridgeBase<ListOffsetsResultInfo>
         {
-            public override string ClassName => "org.apache.kafka.clients.admin.ListOffsetsResult.ListOffsetsResultInfo";
+            public override string ClassName => "org.apache.kafka.clients.admin.ListOffsetsResult$ListOffsetsResultInfo";
 
             [System.Obsolete("This is not public in Apache Kafka API")]
             [System.ComponentModel.EditorBrowsable(System.ComponentModel.EditorBrowsableState.Never)]

diff --git a/src/net/KNet/ClientSide/BridgedClasses/Common/Requests/DescribeLogDirsResponse.cs b/src/net/KNet/ClientSide/BridgedClasses/Common/Requests/DescribeLogDirsResponse.cs
@@ -24,7 +24,7 @@ public class DescribeLogDirsResponse : JCOBridge.C2JBridge.JVMBridgeBase<Describ
 
         public class LogDirInfo : JCOBridge.C2JBridge.JVMBridgeBase<LogDirInfo>
         {
-            public override string ClassName => "org.apache.kafka.common.requests.DescribeLogDirsResponse.LogDirInfo";
+            public override string ClassName => "org.apache.kafka.common.requests.DescribeLogDirsResponse$LogDirInfo";
         }
     }
 }
diff --git a/src/net/KNet/ClientSide/BridgedClasses/Common/TopicCollection.cs b/src/net/KNet/ClientSide/BridgedClasses/Common/TopicCollection.cs
@@ -37,14 +37,14 @@ public static TopicNameCollection OfTopicNames(Collection<string> topics)
 
         public class TopicIdCollection : TopicCollection
         {
-            public override string ClassName => "org.apache.kafka.common.TopicCollection.TopicIdCollection";
+            public override string ClassName => "org.apache.kafka.common.TopicCollection$TopicIdCollection";
 
             public Collection<Uuid> TopicIds => IExecute<Collection<Uuid>>("topicIds");
         }
 
         public class TopicNameCollection : TopicCollection
         {
-            public override string ClassName => "org.apache.kafka.common.TopicCollection.TopicNameCollection";
+            public override string ClassName => "org.apache.kafka.common.TopicCollection$TopicNameCollection";
 
             public Collection<string> TopicNames => IExecute<Collection<string>>("topicNames");
         }

diff --git a/src/net/KNet/ClientSide/BridgedClasses/Connect/Header/Headers.cs b/src/net/KNet/ClientSide/BridgedClasses/Connect/Header/Headers.cs
@@ -106,7 +106,7 @@ public Headers(params object[] args)
         public class HeaderTransform : JVMBridgeBase<HeaderTransform>
         {
             public override bool IsInterface => true;
-            public override string ClassName => "org.apache.kafka.connect.header.Headers.HeaderTransform";
+            public override string ClassName => "org.apache.kafka.connect.header.Headers$HeaderTransform";
 
             public Header Apply(Header header) => IExecute<Header>("apply", header);
         }

diff --git a/src/net/KNet/ClientSide/BridgedClasses/Streams/TopologyDescription.cs b/src/net/KNet/ClientSide/BridgedClasses/Streams/TopologyDescription.cs
@@ -33,7 +33,7 @@ public class TopologyDescription : JVMBridgeBase<TopologyDescription>
 
         public class Subtopology : JVMBridgeBase<Subtopology>
         {
-            public override string ClassName => "org.apache.kafka.streams.TopologyDescription.Subtopology";
+            public override string ClassName => "org.apache.kafka.streams.TopologyDescription$Subtopology";
 
             public int Id => IExecute<int>("id");
 
@@ -42,7 +42,7 @@ public class Subtopology : JVMBridgeBase<Subtopology>
 
         public class GlobalStore : JVMBridgeBase<GlobalStore>
         {
-            public override string ClassName => "org.apache.kafka.streams.TopologyDescription.GlobalStore";
+            public override string ClassName => "org.apache.kafka.streams.TopologyDescription$GlobalStore";
 
             public Source Source => IExecute<Source>("source");
 
@@ -53,7 +53,7 @@ public class GlobalStore : JVMBridgeBase<GlobalStore>
 
         public class Node : JVMBridgeBase<Node>
         {
-            public override string ClassName => "org.apache.kafka.streams.TopologyDescription.Node";
+            public override string ClassName => "org.apache.kafka.streams.TopologyDescription$Node";
 
             public string Name => IExecute<string>("name");
 
@@ -64,7 +64,7 @@ public class Node : JVMBridgeBase<Node>
 
         public class Source : Node
         {
-            public override string ClassName => "org.apache.kafka.streams.TopologyDescription.Source";
+            public override string ClassName => "org.apache.kafka.streams.TopologyDescription$Source";
 
             public Set<string> TopicSet => IExecute<Set<string>>("topicSet");
 
@@ -73,7 +73,7 @@ public class Source : Node
 
         public class Sink : Node
         {
-            public override string ClassName => "org.apache.kafka.streams.TopologyDescription.Sink";
+            public override string ClassName => "org.apache.kafka.streams.TopologyDescription$Sink";
 
             public string Topic => IExecute<string>("topic");
 
@@ -82,7 +82,7 @@ public class Sink : Node
 
         public class Processor : Node
         {
-            public override string ClassName => "org.apache.kafka.streams.TopologyDescription.Processor";
+            public override string ClassName => "org.apache.kafka.streams.TopologyDescription$Processor";
 
             public Set<string> Stores => IExecute<Set<string>>("stores");
         }