Skip to content

Commit

Permalink
Upgrade to JNet 1.5.5 (#181)
Browse files Browse the repository at this point in the history
* #92: update to JNet 1.5.5

* #92: full class review due to breaking change in JCOBridge
  • Loading branch information
masesdevelopers committed May 8, 2023
1 parent 1db3cae commit 9a4af6d
Show file tree
Hide file tree
Showing 583 changed files with 1,021 additions and 1,021 deletions.
4 changes: 2 additions & 2 deletions .github/workflows/build.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -78,7 +78,7 @@ jobs:
gpg-passphrase: MAVEN_GPG_PASSPHRASE # env variable for GPG private key passphrase

- name: Install local file to be used within Javadoc plugin of generated POM
run: mvn install:install-file -DgroupId=JCOBridge -DartifactId=JCOBridge -Dversion=2.5.6 -Dpackaging=jar -Dfile=../../../bin/net6.0/JCOBridge.jar -f ./src/java/knet/pom.xml
run: mvn install:install-file -DgroupId=JCOBridge -DartifactId=JCOBridge -Dversion=2.5.7 -Dpackaging=jar -Dfile=../../../bin/net6.0/JCOBridge.jar -f ./src/java/knet/pom.xml
shell: bash

- name: Create Jars
Expand Down Expand Up @@ -150,7 +150,7 @@ jobs:
gpg-passphrase: MAVEN_GPG_PASSPHRASE # env variable for GPG private key passphrase

- name: Install local file to be used within Javadoc plugin of generated POM
run: mvn install:install-file -DgroupId=JCOBridge -DartifactId=JCOBridge -Dversion=2.5.6 -Dpackaging=jar -Dfile=../../../bin/net6.0/JCOBridge.jar -f ./src/java/knet/pom.xml
run: mvn install:install-file -DgroupId=JCOBridge -DartifactId=JCOBridge -Dversion=2.5.7 -Dpackaging=jar -Dfile=../../../bin/net6.0/JCOBridge.jar -f ./src/java/knet/pom.xml
shell: bash

- name: Create Jars
Expand Down
2 changes: 1 addition & 1 deletion .github/workflows/codeql-analysis.yml
Original file line number Diff line number Diff line change
Expand Up @@ -108,7 +108,7 @@ jobs:

- name: Maven preparation (step 2)
if: matrix.language == 'java'
run: mvn install:install-file -DgroupId=JCOBridge -DartifactId=JCOBridge -Dversion=2.5.6 -Dpackaging=jar -Dfile=../../../bin/net6.0/JCOBridge.jar -f ./src/java/knet/pom.xml
run: mvn install:install-file -DgroupId=JCOBridge -DartifactId=JCOBridge -Dversion=2.5.7 -Dpackaging=jar -Dfile=../../../bin/net6.0/JCOBridge.jar -f ./src/java/knet/pom.xml
shell: bash

- if: matrix.language == 'java'
Expand Down
4 changes: 2 additions & 2 deletions .github/workflows/pullrequest.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,7 @@ jobs:
gpg-passphrase: MAVEN_GPG_PASSPHRASE # env variable for GPG private key passphrase

- name: Install local file to be used within Javadoc plugin of generated POM
run: mvn install:install-file -DgroupId=JCOBridge -DartifactId=JCOBridge -Dversion=2.5.6 -Dpackaging=jar -Dfile=../../../bin/net6.0/JCOBridge.jar -f ./src/java/knet/pom.xml
run: mvn install:install-file -DgroupId=JCOBridge -DartifactId=JCOBridge -Dversion=2.5.7 -Dpackaging=jar -Dfile=../../../bin/net6.0/JCOBridge.jar -f ./src/java/knet/pom.xml
shell: bash

- name: Create Jars
Expand Down Expand Up @@ -120,7 +120,7 @@ jobs:
gpg-passphrase: MAVEN_GPG_PASSPHRASE # env variable for GPG private key passphrase

- name: Install local file to be used within Javadoc plugin of generated POM
run: mvn install:install-file -DgroupId=JCOBridge -DartifactId=JCOBridge -Dversion=2.5.6 -Dpackaging=jar -Dfile=../../../bin/net6.0/JCOBridge.jar -f ./src/java/knet/pom.xml
run: mvn install:install-file -DgroupId=JCOBridge -DartifactId=JCOBridge -Dversion=2.5.7 -Dpackaging=jar -Dfile=../../../bin/net6.0/JCOBridge.jar -f ./src/java/knet/pom.xml
shell: bash

- name: Create Jars
Expand Down
6 changes: 3 additions & 3 deletions .github/workflows/release.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ jobs:
gpg-passphrase: MAVEN_GPG_PASSPHRASE # env variable for GPG private key passphrase

- name: Install local file to be used within Javadoc plugin of generated POM
run: mvn install:install-file -DgroupId=JCOBridge -DartifactId=JCOBridge -Dversion=2.5.6 -Dpackaging=jar -Dfile=../../../bin/net6.0/JCOBridge.jar -f ./src/java/knet/pom.xml
run: mvn install:install-file -DgroupId=JCOBridge -DartifactId=JCOBridge -Dversion=2.5.7 -Dpackaging=jar -Dfile=../../../bin/net6.0/JCOBridge.jar -f ./src/java/knet/pom.xml
shell: bash

- name: Create Jars
Expand Down Expand Up @@ -95,7 +95,7 @@ jobs:
gpg-passphrase: MAVEN_GPG_PASSPHRASE # env variable for GPG private key passphrase

- name: Install local file to be used within Javadoc plugin of generated POM
run: mvn install:install-file -DgroupId=JCOBridge -DartifactId=JCOBridge -Dversion=2.5.6 -Dpackaging=jar -Dfile=../../../bin/net6.0/JCOBridge.jar -f ./src/java/knet/pom.xml
run: mvn install:install-file -DgroupId=JCOBridge -DartifactId=JCOBridge -Dversion=2.5.7 -Dpackaging=jar -Dfile=../../../bin/net6.0/JCOBridge.jar -f ./src/java/knet/pom.xml
shell: bash

- name: Create Jars
Expand Down Expand Up @@ -161,7 +161,7 @@ jobs:
gpg-passphrase: MAVEN_GPG_PASSPHRASE # env variable for GPG private key passphrase

- name: Install local file to be used within Javadoc plugin of generated POM
run: mvn install:install-file -DgroupId=JCOBridge -DartifactId=JCOBridge -Dversion=2.5.6 -Dpackaging=jar -Dfile=../../../bin/net6.0/JCOBridge.jar -f ./src/java/knet/pom.xml
run: mvn install:install-file -DgroupId=JCOBridge -DartifactId=JCOBridge -Dversion=2.5.7 -Dpackaging=jar -Dfile=../../../bin/net6.0/JCOBridge.jar -f ./src/java/knet/pom.xml
shell: bash

- name: Create Jars
Expand Down
2 changes: 1 addition & 1 deletion src/java/knet/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,7 @@
<classpathfile>${basedir}/classpathfile.classpath</classpathfile>
<kafkaVersion>3.4.0</kafkaVersion>
<knetVersion>1.5.3.0</knetVersion>
<jcobridgeVersion>2.5.6</jcobridgeVersion>
<jcobridgeVersion>2.5.7</jcobridgeVersion>
</properties>
<distributionManagement>
<snapshotRepository>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,6 @@ namespace MASES.KNet.Clients.Admin
{
public class AbortTransactionOptions : AbstractOptions<AbortTransactionOptions>
{
public override string ClassName => "org.apache.kafka.clients.admin.AbortTransactionOptions";
public override string BridgeClassName => "org.apache.kafka.clients.admin.AbortTransactionOptions";
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ namespace MASES.KNet.Clients.Admin
{
public class AbortTransactionResult : JCOBridge.C2JBridge.JVMBridgeBase<AbortTransactionResult>
{
public override string ClassName => "org.apache.kafka.clients.admin.AbortTransactionResult";
public override string BridgeClassName => "org.apache.kafka.clients.admin.AbortTransactionResult";

public KafkaFuture<Void> All => IExecute<KafkaFuture<Void>>("all");
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ namespace MASES.KNet.Clients.Admin
{
public class AbortTransactionSpec : JCOBridge.C2JBridge.JVMBridgeBase<AbortTransactionSpec>
{
public override string ClassName => "org.apache.kafka.clients.admin.AbortTransactionSpec";
public override string BridgeClassName => "org.apache.kafka.clients.admin.AbortTransactionSpec";

[System.Obsolete("This is not public in Apache Kafka API")]
[System.ComponentModel.EditorBrowsable(System.ComponentModel.EditorBrowsableState.Never)]
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@ namespace MASES.KNet.Clients.Admin
public class AbstractOptions<T> : JCOBridge.C2JBridge.JVMBridgeBase<AbstractOptions<T>>
where T : AbstractOptions<T>
{
public override string ClassName => "org.apache.kafka.clients.admin.AbstractOptions";
public override string BridgeClassName => "org.apache.kafka.clients.admin.AbstractOptions";

[System.ComponentModel.EditorBrowsable(System.ComponentModel.EditorBrowsableState.Never)]
public AbstractOptions()
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,51 +23,51 @@ namespace MASES.KNet.Clients.Admin
{
public class AdminClientConfig : AbstractConfig<AdminClientConfig>
{
public override string ClassName => "org.apache.kafka.clients.admin.AdminClientConfig";
public override string BridgeClassName => "org.apache.kafka.clients.admin.AdminClientConfig";

public static readonly string BOOTSTRAP_SERVERS_CONFIG = Clazz.GetField<string>("BOOTSTRAP_SERVERS_CONFIG");
public static readonly string BOOTSTRAP_SERVERS_CONFIG = BridgeClazz.GetField<string>("BOOTSTRAP_SERVERS_CONFIG");

public static readonly string CLIENT_DNS_LOOKUP_CONFIG = Clazz.GetField<string>("CLIENT_DNS_LOOKUP_CONFIG");
public static readonly string CLIENT_DNS_LOOKUP_CONFIG = BridgeClazz.GetField<string>("CLIENT_DNS_LOOKUP_CONFIG");

public static readonly string RECONNECT_BACKOFF_MS_CONFIG = Clazz.GetField<string>("RECONNECT_BACKOFF_MS_CONFIG");
public static readonly string RECONNECT_BACKOFF_MS_CONFIG = BridgeClazz.GetField<string>("RECONNECT_BACKOFF_MS_CONFIG");

public static readonly string RECONNECT_BACKOFF_MAX_MS_CONFIG = Clazz.GetField<string>("RECONNECT_BACKOFF_MAX_MS_CONFIG");
public static readonly string RECONNECT_BACKOFF_MAX_MS_CONFIG = BridgeClazz.GetField<string>("RECONNECT_BACKOFF_MAX_MS_CONFIG");

public static readonly string RETRY_BACKOFF_MS_CONFIG = Clazz.GetField<string>("RETRY_BACKOFF_MS_CONFIG");
public static readonly string RETRY_BACKOFF_MS_CONFIG = BridgeClazz.GetField<string>("RETRY_BACKOFF_MS_CONFIG");

public static readonly string SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIG = Clazz.GetField<string>("SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIG");
public static readonly string SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIG = BridgeClazz.GetField<string>("SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIG");

public static readonly string SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIG = Clazz.GetField<string>("SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIG");
public static readonly string SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIG = BridgeClazz.GetField<string>("SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIG");

public static readonly string CONNECTIONS_MAX_IDLE_MS_CONFIG = Clazz.GetField<string>("CONNECTIONS_MAX_IDLE_MS_CONFIG");
public static readonly string CONNECTIONS_MAX_IDLE_MS_CONFIG = BridgeClazz.GetField<string>("CONNECTIONS_MAX_IDLE_MS_CONFIG");

public static readonly string REQUEST_TIMEOUT_MS_CONFIG = Clazz.GetField<string>("REQUEST_TIMEOUT_MS_CONFIG");
public static readonly string REQUEST_TIMEOUT_MS_CONFIG = BridgeClazz.GetField<string>("REQUEST_TIMEOUT_MS_CONFIG");

public static readonly string CLIENT_ID_CONFIG = Clazz.GetField<string>("CLIENT_ID_CONFIG");
public static readonly string CLIENT_ID_CONFIG = BridgeClazz.GetField<string>("CLIENT_ID_CONFIG");

public static readonly string METADATA_MAX_AGE_CONFIG = Clazz.GetField<string>("METADATA_MAX_AGE_CONFIG");
public static readonly string METADATA_MAX_AGE_CONFIG = BridgeClazz.GetField<string>("METADATA_MAX_AGE_CONFIG");

public static readonly string SEND_BUFFER_CONFIG = Clazz.GetField<string>("SEND_BUFFER_CONFIG");
public static readonly string SEND_BUFFER_CONFIG = BridgeClazz.GetField<string>("SEND_BUFFER_CONFIG");

public static readonly string RECEIVE_BUFFER_CONFIG = Clazz.GetField<string>("RECEIVE_BUFFER_CONFIG");
public static readonly string RECEIVE_BUFFER_CONFIG = BridgeClazz.GetField<string>("RECEIVE_BUFFER_CONFIG");

public static readonly string METRIC_REPORTER_CLASSES_CONFIG = Clazz.GetField<string>("METRIC_REPORTER_CLASSES_CONFIG");
public static readonly string METRIC_REPORTER_CLASSES_CONFIG = BridgeClazz.GetField<string>("METRIC_REPORTER_CLASSES_CONFIG");

public static readonly string AUTO_INCLUDE_JMX_REPORTER_CONFIG = Clazz.GetField<string>("AUTO_INCLUDE_JMX_REPORTER_CONFIG");
public static readonly string AUTO_INCLUDE_JMX_REPORTER_CONFIG = BridgeClazz.GetField<string>("AUTO_INCLUDE_JMX_REPORTER_CONFIG");

public static readonly string METRICS_NUM_SAMPLES_CONFIG = Clazz.GetField<string>("METRICS_NUM_SAMPLES_CONFIG");
public static readonly string METRICS_NUM_SAMPLES_CONFIG = BridgeClazz.GetField<string>("METRICS_NUM_SAMPLES_CONFIG");

public static readonly string METRICS_SAMPLE_WINDOW_MS_CONFIG = Clazz.GetField<string>("METRICS_SAMPLE_WINDOW_MS_CONFIG");
public static readonly string METRICS_SAMPLE_WINDOW_MS_CONFIG = BridgeClazz.GetField<string>("METRICS_SAMPLE_WINDOW_MS_CONFIG");

public static readonly string METRICS_RECORDING_LEVEL_CONFIG = Clazz.GetField<string>("METRICS_RECORDING_LEVEL_CONFIG");
public static readonly string METRICS_RECORDING_LEVEL_CONFIG = BridgeClazz.GetField<string>("METRICS_RECORDING_LEVEL_CONFIG");

public static readonly string SECURITY_PROTOCOL_CONFIG = Clazz.GetField<string>("SECURITY_PROTOCOL_CONFIG");
public static readonly string DEFAULT_SECURITY_PROTOCOL = Clazz.GetField<string>("DEFAULT_SECURITY_PROTOCOL");
public static readonly string SECURITY_PROTOCOL_CONFIG = BridgeClazz.GetField<string>("SECURITY_PROTOCOL_CONFIG");
public static readonly string DEFAULT_SECURITY_PROTOCOL = BridgeClazz.GetField<string>("DEFAULT_SECURITY_PROTOCOL");

public static readonly string RETRIES_CONFIG = Clazz.GetField<string>("RETRIES_CONFIG");
public static readonly string DEFAULT_API_TIMEOUT_MS_CONFIG = Clazz.GetField<string>("DEFAULT_API_TIMEOUT_MS_CONFIG");
public static readonly string RETRIES_CONFIG = BridgeClazz.GetField<string>("RETRIES_CONFIG");
public static readonly string DEFAULT_API_TIMEOUT_MS_CONFIG = BridgeClazz.GetField<string>("DEFAULT_API_TIMEOUT_MS_CONFIG");

public static readonly string SECURITY_PROVIDERS_CONFIG = Clazz.GetField<string>("SECURITY_PROVIDERS_CONFIG");
public static readonly string SECURITY_PROVIDERS_CONFIG = BridgeClazz.GetField<string>("SECURITY_PROVIDERS_CONFIG");

[System.Obsolete("This is not public in Apache Kafka API")]
[System.ComponentModel.EditorBrowsable(System.ComponentModel.EditorBrowsableState.Never)]
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ namespace MASES.KNet.Clients.Admin
{
public class AlterClientQuotasOptions : AbstractOptions<AlterClientQuotasOptions>
{
public override string ClassName => "org.apache.kafka.clients.admin.AlterClientQuotasOptions";
public override string BridgeClassName => "org.apache.kafka.clients.admin.AlterClientQuotasOptions";

public bool ValidateOnly() => IExecute<bool>("validateOnly");

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ namespace MASES.KNet.Clients.Admin
{
public class AlterClientQuotasResult : JCOBridge.C2JBridge.JVMBridgeBase<AlterClientQuotasResult>
{
public override string ClassName => "org.apache.kafka.clients.admin.AlterClientQuotasResult";
public override string BridgeClassName => "org.apache.kafka.clients.admin.AlterClientQuotasResult";

public Map<ClientQuotaEntity, KafkaFuture<Void>> Values => IExecute<Map<ClientQuotaEntity, KafkaFuture<Void>>>("values");

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ namespace MASES.KNet.Clients.Admin
{
public class AlterConfigOp : JCOBridge.C2JBridge.JVMBridgeBase<AlterConfigOp>
{
public override string ClassName => "org.apache.kafka.clients.admin.AlterConfigOp";
public override string BridgeClassName => "org.apache.kafka.clients.admin.AlterConfigOp";
}
}

Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ namespace MASES.KNet.Clients.Admin
{
public class AlterConfigsOptions : AbstractOptions<AlterConfigsOptions>
{
public override string ClassName => "org.apache.kafka.clients.admin.AlterConfigsOptions";
public override string BridgeClassName => "org.apache.kafka.clients.admin.AlterConfigsOptions";

public new AlterConfigsOptions TimeoutMs(int timeoutMs)
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ namespace MASES.KNet.Clients.Admin
{
public class AlterConfigsResult : JCOBridge.C2JBridge.JVMBridgeBase<AlterConfigsResult>
{
public override string ClassName => "org.apache.kafka.clients.admin.AlterConfigsResult";
public override string BridgeClassName => "org.apache.kafka.clients.admin.AlterConfigsResult";

public Map<ConfigResource, KafkaFuture<Void>> Values => IExecute<Map<ConfigResource, KafkaFuture<Void>>>("values");

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,6 @@ namespace MASES.KNet.Clients.Admin
{
public class AlterConsumerGroupOffsetsOptions : AbstractOptions<AlterConsumerGroupOffsetsOptions>
{
public override string ClassName => "org.apache.kafka.clients.admin.AlterConsumerGroupOffsetsOptions";
public override string BridgeClassName => "org.apache.kafka.clients.admin.AlterConsumerGroupOffsetsOptions";
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ namespace MASES.KNet.Clients.Admin
{
public class AlterConsumerGroupOffsetsResult : JCOBridge.C2JBridge.JVMBridgeBase<AlterConsumerGroupOffsetsResult>
{
public override string ClassName => "org.apache.kafka.clients.admin.AlterConsumerGroupOffsetsResult";
public override string BridgeClassName => "org.apache.kafka.clients.admin.AlterConsumerGroupOffsetsResult";

public KafkaFuture<Void> PartitionResult(TopicPartition partition)
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,6 @@ namespace MASES.KNet.Clients.Admin
{
public class AlterPartitionReassignmentsOptions : AbstractOptions<AlterPartitionReassignmentsOptions>
{
public override string ClassName => "org.apache.kafka.clients.admin.AlterPartitionReassignmentsOptions";
public override string BridgeClassName => "org.apache.kafka.clients.admin.AlterPartitionReassignmentsOptions";
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ namespace MASES.KNet.Clients.Admin
{
public class AlterPartitionReassignmentsResult : JCOBridge.C2JBridge.JVMBridgeBase<AlterPartitionReassignmentsResult>
{
public override string ClassName => "org.apache.kafka.clients.admin.AlterPartitionReassignmentsResult";
public override string BridgeClassName => "org.apache.kafka.clients.admin.AlterPartitionReassignmentsResult";

public Map<TopicPartition, KafkaFuture<Void>> Values => IExecute<Map<TopicPartition, KafkaFuture<Void>>>("values");

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,6 @@ namespace MASES.KNet.Clients.Admin
{
public class AlterReplicaLogDirsOptions : AbstractOptions<AlterReplicaLogDirsOptions>
{
public override string ClassName => "org.apache.kafka.clients.admin.AlterReplicaLogDirsOptions";
public override string BridgeClassName => "org.apache.kafka.clients.admin.AlterReplicaLogDirsOptions";
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ namespace MASES.KNet.Clients.Admin
{
public class AlterReplicaLogDirsResult : JCOBridge.C2JBridge.JVMBridgeBase<AlterReplicaLogDirsResult>
{
public override string ClassName => "org.apache.kafka.clients.admin.AlterReplicaLogDirsResult";
public override string BridgeClassName => "org.apache.kafka.clients.admin.AlterReplicaLogDirsResult";

public Map<TopicPartitionReplica, KafkaFuture<Void>> Values => IExecute<Map<TopicPartitionReplica, KafkaFuture<Void>>>("values");

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,6 @@ namespace MASES.KNet.Clients.Admin
{
public class AlterUserScramCredentialsOptions : AbstractOptions<AlterUserScramCredentialsOptions>
{
public override string ClassName => "org.apache.kafka.clients.admin.AlterUserScramCredentialsOptions";
public override string BridgeClassName => "org.apache.kafka.clients.admin.AlterUserScramCredentialsOptions";
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ namespace MASES.KNet.Clients.Admin
{
public class AlterUserScramCredentialsResult : JCOBridge.C2JBridge.JVMBridgeBase<AlterUserScramCredentialsResult>
{
public override string ClassName => "org.apache.kafka.clients.admin.AlterUserScramCredentialsResult";
public override string BridgeClassName => "org.apache.kafka.clients.admin.AlterUserScramCredentialsResult";

public Map<string, KafkaFuture<Void>> Values => IExecute<Map<string, KafkaFuture<Void>>>("values");

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ namespace MASES.KNet.Clients.Admin
{
public class Config : JCOBridge.C2JBridge.JVMBridgeBase<Config>
{
public override string ClassName => "org.apache.kafka.clients.admin.Config";
public override string BridgeClassName => "org.apache.kafka.clients.admin.Config";

[System.Obsolete("This is not public in Apache Kafka API")]
[System.ComponentModel.EditorBrowsable(System.ComponentModel.EditorBrowsableState.Never)]
Expand Down
Loading

0 comments on commit 9a4af6d

Please sign in to comment.