From 8b99eff32bc44946f2b32bde186907ed48d5af1d Mon Sep 17 00:00:00 2001
From: masesdevelopers <94312179+masesdevelopers@users.noreply.github.com>
Date: Thu, 29 Feb 2024 22:46:55 +0000
Subject: [PATCH] Update generated classes after commit 9bf7012
---
.../clients/consumer/ConsumerInterceptor.java | 2 +-
.../consumer/ConsumerPartitionAssignor.java | 2 +-
.../consumer/ConsumerRebalanceListener.java | 2 +-
.../consumer/OffsetCommitCallback.java | 2 +-
.../kafka/clients/producer/Callback.java | 2 +-
.../kafka/clients/producer/Partitioner.java | 2 +-
.../clients/producer/ProducerInterceptor.java | 2 +-
.../kafka/common/ClusterResourceListener.java | 2 +-
.../common/config/ConfigChangeCallback.java | 2 +-
.../kafka/common/metrics/MetricsReporter.java | 2 +-
.../common/serialization/Deserializer.java | 2 +-
.../kafka/common/serialization/Serde.java | 2 +-
.../common/serialization/Serializer.java | 2 +-
.../org/apache/kafka/raft/Listener.java | 2 +-
.../kafka/streams/KafkaClientSupplier.java | 2 +-
.../apache/kafka/streams/StateListener.java | 2 +-
.../StreamsUncaughtExceptionHandler.java | 2 +-
.../kafka/streams/kstream/Aggregator.java | 2 +-
.../kafka/streams/kstream/ForeachAction.java | 2 +-
.../kafka/streams/kstream/Initializer.java | 2 +-
.../kafka/streams/kstream/KeyValueMapper.java | 2 +-
.../apache/kafka/streams/kstream/Merger.java | 2 +-
.../kafka/streams/kstream/Predicate.java | 2 +-
.../apache/kafka/streams/kstream/Reducer.java | 2 +-
.../kafka/streams/kstream/Transformer.java | 2 +-
.../kafka/streams/kstream/ValueJoiner.java | 2 +-
.../streams/kstream/ValueJoinerWithKey.java | 2 +-
.../kafka/streams/kstream/ValueMapper.java | 2 +-
.../streams/kstream/ValueMapperWithKey.java | 2 +-
.../streams/kstream/ValueTransformer.java | 2 +-
.../kstream/ValueTransformerWithKey.java | 2 +-
.../BatchingStateRestoreCallback.java | 2 +-
.../kafka/streams/processor/Punctuator.java | 2 +-
.../processor/StateRestoreCallback.java | 2 +-
.../processor/StateRestoreListener.java | 2 +-
.../streams/processor/StreamPartitioner.java | 2 +-
.../streams/processor/TimestampExtractor.java | 2 +-
.../streams/processor/TopicNameExtractor.java | 2 +-
.../processor/api/FixedKeyProcessor.java | 2 +-
.../streams/processor/api/Processor.java | 2 +-
.../KNet/Generated/Kafka/Admin/AclCommand.cs | 60 +++---
.../Kafka/Admin/AllPackageClasses.cs | 2 +-
.../Kafka/Admin/BrokerApiVersionsCommand.cs | 10 +-
.../Generated/Kafka/Admin/ConfigCommand.cs | 46 ++---
.../Kafka/Admin/ConsumerGroupCommand.cs | 182 +++++++++---------
.../Generated/Kafka/Admin/FeatureCommand.cs | 4 +-
.../Kafka/Admin/LeaderElectionCommand.cs | 8 +-
.../Admin/LeaderElectionCommandOptions.cs | 2 +-
.../Generated/Kafka/Admin/RackAwareMode.cs | 2 +-
.../Kafka/Admin/ReassignPartitionsCommand.cs | 136 ++++++-------
.../Generated/Kafka/Admin/TopicCommand.cs | 130 ++++++-------
.../Kafka/Admin/ZkSecurityMigrator.cs | 20 +-
.../KNet/Generated/Kafka/AllPackageClasses.cs | 2 +-
.../Clients/Admin/AbortTransactionOptions.cs | 2 +-
.../Clients/Admin/AbortTransactionResult.cs | 4 +-
.../Clients/Admin/AbortTransactionSpec.cs | 10 +-
.../Kafka/Clients/Admin/AbstractOptions.cs | 10 +-
.../Org/Apache/Kafka/Clients/Admin/Admin.cs | 116 +++++------
.../Apache/Kafka/Clients/Admin/AdminClient.cs | 2 +-
.../Kafka/Clients/Admin/AdminClientConfig.cs | 8 +-
.../Kafka/Clients/Admin/AllPackageClasses.cs | 2 +-
.../Clients/Admin/AlterClientQuotasOptions.cs | 6 +-
.../Clients/Admin/AlterClientQuotasResult.cs | 6 +-
.../Kafka/Clients/Admin/AlterConfigOp.cs | 14 +-
.../Clients/Admin/AlterConfigsOptions.cs | 6 +-
.../Kafka/Clients/Admin/AlterConfigsResult.cs | 6 +-
.../Admin/AlterConsumerGroupOffsetsOptions.cs | 2 +-
.../Admin/AlterConsumerGroupOffsetsResult.cs | 6 +-
.../AlterPartitionReassignmentsOptions.cs | 2 +-
.../AlterPartitionReassignmentsResult.cs | 6 +-
.../Admin/AlterReplicaLogDirsOptions.cs | 2 +-
.../Admin/AlterReplicaLogDirsResult.cs | 6 +-
.../Admin/AlterUserScramCredentialsOptions.cs | 2 +-
.../Admin/AlterUserScramCredentialsResult.cs | 6 +-
.../Org/Apache/Kafka/Clients/Admin/Config.cs | 6 +-
.../Apache/Kafka/Clients/Admin/ConfigEntry.cs | 34 ++--
.../Clients/Admin/ConsumerGroupDescription.cs | 16 +-
.../Clients/Admin/ConsumerGroupListing.cs | 8 +-
.../Kafka/Clients/Admin/CreateAclsOptions.cs | 2 +-
.../Kafka/Clients/Admin/CreateAclsResult.cs | 6 +-
.../Admin/CreateDelegationTokenOptions.cs | 14 +-
.../Admin/CreateDelegationTokenResult.cs | 4 +-
.../Clients/Admin/CreatePartitionsOptions.cs | 10 +-
.../Clients/Admin/CreatePartitionsResult.cs | 6 +-
.../Clients/Admin/CreateTopicsOptions.cs | 10 +-
.../Kafka/Clients/Admin/CreateTopicsResult.cs | 22 +--
.../Kafka/Clients/Admin/DeleteAclsOptions.cs | 2 +-
.../Kafka/Clients/Admin/DeleteAclsResult.cs | 12 +-
.../DeleteConsumerGroupOffsetsOptions.cs | 2 +-
.../Admin/DeleteConsumerGroupOffsetsResult.cs | 6 +-
.../Admin/DeleteConsumerGroupsOptions.cs | 2 +-
.../Admin/DeleteConsumerGroupsResult.cs | 6 +-
.../Clients/Admin/DeleteRecordsOptions.cs | 2 +-
.../Clients/Admin/DeleteRecordsResult.cs | 6 +-
.../Clients/Admin/DeleteTopicsOptions.cs | 6 +-
.../Kafka/Clients/Admin/DeleteTopicsResult.cs | 8 +-
.../Kafka/Clients/Admin/DeletedRecords.cs | 4 +-
.../Clients/Admin/DescribeAclsOptions.cs | 2 +-
.../Kafka/Clients/Admin/DescribeAclsResult.cs | 4 +-
.../Admin/DescribeClientQuotasOptions.cs | 2 +-
.../Admin/DescribeClientQuotasResult.cs | 4 +-
.../Clients/Admin/DescribeClusterOptions.cs | 6 +-
.../Clients/Admin/DescribeClusterResult.cs | 10 +-
.../Clients/Admin/DescribeConfigsOptions.cs | 10 +-
.../Clients/Admin/DescribeConfigsResult.cs | 6 +-
.../Admin/DescribeConsumerGroupsOptions.cs | 6 +-
.../Admin/DescribeConsumerGroupsResult.cs | 6 +-
.../Admin/DescribeDelegationTokenOptions.cs | 6 +-
.../Admin/DescribeDelegationTokenResult.cs | 4 +-
.../Clients/Admin/DescribeFeaturesOptions.cs | 2 +-
.../Clients/Admin/DescribeFeaturesResult.cs | 4 +-
.../Clients/Admin/DescribeLogDirsOptions.cs | 2 +-
.../Clients/Admin/DescribeLogDirsResult.cs | 6 +-
.../Admin/DescribeMetadataQuorumOptions.cs | 2 +-
.../Admin/DescribeMetadataQuorumResult.cs | 4 +-
.../Clients/Admin/DescribeProducersOptions.cs | 6 +-
.../Clients/Admin/DescribeProducersResult.cs | 8 +-
.../Admin/DescribeReplicaLogDirsOptions.cs | 2 +-
.../Admin/DescribeReplicaLogDirsResult.cs | 14 +-
.../Clients/Admin/DescribeTopicsOptions.cs | 6 +-
.../Clients/Admin/DescribeTopicsResult.cs | 10 +-
.../Admin/DescribeTransactionsOptions.cs | 2 +-
.../Admin/DescribeTransactionsResult.cs | 6 +-
.../DescribeUserScramCredentialsOptions.cs | 2 +-
.../DescribeUserScramCredentialsResult.cs | 8 +-
.../Clients/Admin/ElectLeadersOptions.cs | 2 +-
.../Kafka/Clients/Admin/ElectLeadersResult.cs | 6 +-
.../Admin/ExpireDelegationTokenOptions.cs | 6 +-
.../Admin/ExpireDelegationTokenResult.cs | 4 +-
.../Kafka/Clients/Admin/FeatureMetadata.cs | 8 +-
.../Kafka/Clients/Admin/FeatureUpdate.cs | 14 +-
.../Clients/Admin/FenceProducersOptions.cs | 2 +-
.../Clients/Admin/FenceProducersResult.cs | 10 +-
.../Clients/Admin/FinalizedVersionRange.cs | 6 +-
.../Kafka/Clients/Admin/ForwardingAdmin.cs | 22 +--
.../Kafka/Clients/Admin/KafkaAdminClient.cs | 2 +-
.../Admin/ListConsumerGroupOffsetsOptions.cs | 6 +-
.../Admin/ListConsumerGroupOffsetsResult.cs | 8 +-
.../Admin/ListConsumerGroupOffsetsSpec.cs | 6 +-
.../Admin/ListConsumerGroupsOptions.cs | 6 +-
.../Clients/Admin/ListConsumerGroupsResult.cs | 8 +-
.../Kafka/Clients/Admin/ListOffsetsOptions.cs | 4 +-
.../Kafka/Clients/Admin/ListOffsetsResult.cs | 12 +-
.../ListPartitionReassignmentsOptions.cs | 2 +-
.../Admin/ListPartitionReassignmentsResult.cs | 4 +-
.../Kafka/Clients/Admin/ListTopicsOptions.cs | 6 +-
.../Kafka/Clients/Admin/ListTopicsResult.cs | 8 +-
.../Clients/Admin/ListTransactionsOptions.cs | 10 +-
.../Clients/Admin/ListTransactionsResult.cs | 8 +-
.../Kafka/Clients/Admin/LogDirDescription.cs | 10 +-
.../Kafka/Clients/Admin/MemberAssignment.cs | 4 +-
.../Kafka/Clients/Admin/MemberDescription.cs | 12 +-
.../Kafka/Clients/Admin/MemberToRemove.cs | 4 +-
.../Clients/Admin/NewPartitionReassignment.cs | 4 +-
.../Kafka/Clients/Admin/NewPartitions.cs | 8 +-
.../Apache/Kafka/Clients/Admin/NewTopic.cs | 14 +-
.../Apache/Kafka/Clients/Admin/OffsetSpec.cs | 10 +-
.../Clients/Admin/PartitionReassignment.cs | 8 +-
.../Kafka/Clients/Admin/ProducerState.cs | 14 +-
.../Apache/Kafka/Clients/Admin/QuorumInfo.cs | 20 +-
.../Kafka/Clients/Admin/RecordsToDelete.cs | 6 +-
.../RemoveMembersFromConsumerGroupOptions.cs | 10 +-
.../RemoveMembersFromConsumerGroupResult.cs | 6 +-
.../Admin/RenewDelegationTokenOptions.cs | 6 +-
.../Admin/RenewDelegationTokenResult.cs | 4 +-
.../Apache/Kafka/Clients/Admin/ReplicaInfo.cs | 8 +-
.../Clients/Admin/ScramCredentialInfo.cs | 6 +-
.../Kafka/Clients/Admin/ScramMechanism.cs | 14 +-
.../Clients/Admin/SupportedVersionRange.cs | 6 +-
.../Kafka/Clients/Admin/TopicDescription.cs | 12 +-
.../Kafka/Clients/Admin/TopicListing.cs | 8 +-
.../Clients/Admin/TransactionDescription.cs | 16 +-
.../Kafka/Clients/Admin/TransactionListing.cs | 8 +-
.../Kafka/Clients/Admin/TransactionState.cs | 8 +-
.../Clients/Admin/UnregisterBrokerOptions.cs | 2 +-
.../Clients/Admin/UnregisterBrokerResult.cs | 4 +-
.../Clients/Admin/UpdateFeaturesOptions.cs | 6 +-
.../Clients/Admin/UpdateFeaturesResult.cs | 6 +-
.../Admin/UserScramCredentialAlteration.cs | 4 +-
.../Admin/UserScramCredentialDeletion.cs | 4 +-
.../Admin/UserScramCredentialUpsertion.cs | 8 +-
.../Admin/UserScramCredentialsDescription.cs | 6 +-
.../Apache/Kafka/Clients/AllPackageClasses.cs | 2 +-
.../Org/Apache/Kafka/Clients/ApiVersions.cs | 8 +-
.../Apache/Kafka/Clients/ClientDnsLookup.cs | 8 +-
.../Apache/Kafka/Clients/ClientResponse.cs | 20 +-
.../Org/Apache/Kafka/Clients/ClientUtils.cs | 4 +-
.../Kafka/Clients/CommonClientConfigs.cs | 6 +-
.../Apache/Kafka/Clients/ConnectionState.cs | 10 +-
.../Clients/Consumer/AllPackageClasses.cs | 2 +-
.../Clients/Consumer/CommitFailedException.cs | 2 +-
.../Apache/Kafka/Clients/Consumer/Consumer.cs | 134 ++++++-------
.../Kafka/Clients/Consumer/ConsumerConfig.cs | 8 +-
.../Clients/Consumer/ConsumerGroupMetadata.cs | 10 +-
.../Clients/Consumer/ConsumerInterceptor.cs | 2 +-
.../Consumer/ConsumerPartitionAssignor.cs | 38 ++--
.../Consumer/ConsumerRebalanceListener.cs | 4 +-
.../Kafka/Clients/Consumer/ConsumerRecord.cs | 46 ++---
.../Kafka/Clients/Consumer/ConsumerRecords.cs | 26 +--
.../Consumer/CooperativeStickyAssignor.cs | 2 +-
.../Consumer/InvalidOffsetException.cs | 2 +-
.../Kafka/Clients/Consumer/KafkaConsumer.cs | 134 ++++++-------
.../Consumer/LogTruncationException.cs | 2 +-
.../Kafka/Clients/Consumer/MockConsumer.cs | 182 +++++++++---------
.../Consumer/NoOffsetForPartitionException.cs | 2 +-
.../Clients/Consumer/OffsetAndMetadata.cs | 8 +-
.../Clients/Consumer/OffsetAndTimestamp.cs | 8 +-
.../Clients/Consumer/OffsetCommitCallback.cs | 2 +-
.../Consumer/OffsetOutOfRangeException.cs | 2 +-
.../Clients/Consumer/OffsetResetStrategy.cs | 6 +-
.../Kafka/Clients/Consumer/RangeAssignor.cs | 2 +-
.../RetriableCommitFailedException.cs | 2 +-
.../Clients/Consumer/RoundRobinAssignor.cs | 2 +-
.../Kafka/Clients/Consumer/StickyAssignor.cs | 2 +-
.../Kafka/Clients/DefaultHostResolver.cs | 4 +-
.../Kafka/Clients/GroupRebalanceConfig.cs | 6 +-
.../Org/Apache/Kafka/Clients/HostResolver.cs | 4 +-
.../Kafka/Clients/ManualMetadataUpdater.cs | 12 +-
.../Org/Apache/Kafka/Clients/Metadata.cs | 44 ++---
.../Org/Apache/Kafka/Clients/MetadataCache.cs | 2 +-
.../Apache/Kafka/Clients/MetadataUpdater.cs | 10 +-
.../Kafka/Clients/NetworkClientUtils.cs | 2 +-
.../Apache/Kafka/Clients/NodeApiVersions.cs | 8 +-
.../Clients/Producer/AllPackageClasses.cs | 2 +-
.../Producer/BufferExhaustedException.cs | 2 +-
.../Apache/Kafka/Clients/Producer/Callback.cs | 2 +-
.../Kafka/Clients/Producer/KafkaProducer.cs | 42 ++--
.../Kafka/Clients/Producer/MockProducer.cs | 106 +++++-----
.../Kafka/Clients/Producer/Partitioner.cs | 2 +-
.../Apache/Kafka/Clients/Producer/Producer.cs | 42 ++--
.../Kafka/Clients/Producer/ProducerConfig.cs | 8 +-
.../Clients/Producer/ProducerInterceptor.cs | 2 +-
.../Kafka/Clients/Producer/ProducerRecord.cs | 26 +--
.../Kafka/Clients/Producer/RecordMetadata.cs | 18 +-
.../Clients/Producer/RoundRobinPartitioner.cs | 6 +-
.../Kafka/Clients/RequestCompletionHandler.cs | 4 +-
.../Kafka/Clients/StaleMetadataException.cs | 2 +-
.../Kafka/Common/Acl/AccessControlEntry.cs | 14 +-
.../Common/Acl/AccessControlEntryFilter.cs | 18 +-
.../Org/Apache/Kafka/Common/Acl/AclBinding.cs | 10 +-
.../Kafka/Common/Acl/AclBindingFilter.cs | 14 +-
.../Apache/Kafka/Common/Acl/AclOperation.cs | 14 +-
.../Kafka/Common/Acl/AclPermissionType.cs | 14 +-
.../Kafka/Common/Acl/AllPackageClasses.cs | 2 +-
.../Apache/Kafka/Common/AllPackageClasses.cs | 2 +-
.../Common/Annotation/AllPackageClasses.cs | 2 +-
.../Common/Annotation/InterfaceStability.cs | 2 +-
.../Kafka/Common/Cache/AllPackageClasses.cs | 2 +-
.../Org/Apache/Kafka/Common/Cache/Cache.cs | 14 +-
.../Org/Apache/Kafka/Common/Cache/LRUCache.cs | 14 +-
.../Kafka/Common/Cache/SynchronizedCache.cs | 14 +-
.../Org/Apache/Kafka/Common/Cluster.cs | 44 ++---
.../Apache/Kafka/Common/ClusterResource.cs | 4 +-
.../Kafka/Common/ClusterResourceListener.cs | 2 +-
.../Common/Compress/AllPackageClasses.cs | 2 +-
.../Compress/KafkaLZ4BlockInputStream.cs | 4 +-
.../Compress/KafkaLZ4BlockOutputStream.cs | 24 +--
.../Kafka/Common/Compress/SnappyFactory.cs | 6 +-
.../Kafka/Common/Compress/ZstdFactory.cs | 4 +-
.../Kafka/Common/Config/AbstractConfig.cs | 46 ++---
.../Kafka/Common/Config/AllPackageClasses.cs | 2 +-
.../Org/Apache/Kafka/Common/Config/Config.cs | 4 +-
.../Common/Config/ConfigChangeCallback.cs | 2 +-
.../Apache/Kafka/Common/Config/ConfigData.cs | 6 +-
.../Apache/Kafka/Common/Config/ConfigDef.cs | 68 +++----
.../Kafka/Common/Config/ConfigException.cs | 2 +-
.../Kafka/Common/Config/ConfigResource.cs | 16 +-
.../Kafka/Common/Config/ConfigTransformer.cs | 4 +-
.../Common/Config/ConfigTransformerResult.cs | 6 +-
.../Apache/Kafka/Common/Config/ConfigValue.cs | 20 +-
.../Kafka/Common/Config/LogLevelConfig.cs | 2 +-
.../Config/Provider/AllPackageClasses.cs | 2 +-
.../Common/Config/Provider/ConfigProvider.cs | 6 +-
.../Provider/DirectoryConfigProvider.cs | 8 +-
.../Config/Provider/EnvVarConfigProvider.cs | 8 +-
.../Config/Provider/FileConfigProvider.cs | 8 +-
.../Apache/Kafka/Common/Config/SaslConfigs.cs | 4 +-
.../Kafka/Common/Config/SecurityConfig.cs | 2 +-
.../Kafka/Common/Config/SslClientAuth.cs | 8 +-
.../Apache/Kafka/Common/Config/SslConfigs.cs | 4 +-
.../Apache/Kafka/Common/Config/TopicConfig.cs | 2 +-
.../Common/Config/Types/AllPackageClasses.cs | 2 +-
.../Kafka/Common/Config/Types/Password.cs | 4 +-
.../Org/Apache/Kafka/Common/Configurable.cs | 4 +-
.../Apache/Kafka/Common/ConsumerGroupState.cs | 8 +-
.../Org/Apache/Kafka/Common/ElectionType.cs | 8 +-
.../Org/Apache/Kafka/Common/Endpoint.cs | 10 +-
.../Kafka/Common/Errors/AllPackageClasses.cs | 2 +-
.../Kafka/Common/Errors/ApiException.cs | 2 +-
.../Common/Errors/AuthenticationException.cs | 2 +-
.../Common/Errors/AuthorizationException.cs | 2 +-
.../Errors/AuthorizerNotReadyException.cs | 2 +-
.../Errors/BrokerIdNotRegisteredException.cs | 2 +-
.../Errors/BrokerNotAvailableException.cs | 2 +-
.../Errors/ClusterAuthorizationException.cs | 2 +-
.../Errors/ConcurrentTransactionsException.cs | 2 +-
.../Common/Errors/ControllerMovedException.cs | 2 +-
.../CoordinatorLoadInProgressException.cs | 2 +-
.../CoordinatorNotAvailableException.cs | 2 +-
.../Common/Errors/CorruptRecordException.cs | 2 +-
.../DelegationTokenAuthorizationException.cs | 2 +-
.../DelegationTokenDisabledException.cs | 2 +-
.../Errors/DelegationTokenExpiredException.cs | 2 +-
.../DelegationTokenNotFoundException.cs | 2 +-
.../DelegationTokenOwnerMismatchException.cs | 2 +-
.../Common/Errors/DisconnectException.cs | 2 +-
.../DuplicateBrokerRegistrationException.cs | 2 +-
.../Errors/DuplicateResourceException.cs | 2 +-
.../Errors/DuplicateSequenceException.cs | 2 +-
.../Errors/ElectionNotNeededException.cs | 2 +-
.../EligibleLeadersNotAvailableException.cs | 2 +-
.../Errors/FeatureUpdateFailedException.cs | 2 +-
.../Errors/FencedInstanceIdException.cs | 2 +-
.../Errors/FencedLeaderEpochException.cs | 2 +-
.../Errors/FencedMemberEpochException.cs | 2 +-
.../Errors/FetchSessionIdNotFoundException.cs | 2 +-
.../Errors/FetchSessionTopicIdException.cs | 2 +-
.../Errors/GroupAuthorizationException.cs | 2 +-
.../Common/Errors/GroupIdNotFoundException.cs | 2 +-
.../Errors/GroupMaxSizeReachedException.cs | 2 +-
.../Common/Errors/GroupNotEmptyException.cs | 2 +-
.../Errors/GroupSubscribedToTopicException.cs | 2 +-
.../Errors/IllegalGenerationException.cs | 2 +-
.../Errors/IllegalSaslStateException.cs | 2 +-
.../Errors/InconsistentClusterIdException.cs | 2 +-
.../InconsistentGroupProtocolException.cs | 2 +-
.../Errors/InconsistentTopicIdException.cs | 2 +-
.../Errors/InconsistentVoterSetException.cs | 2 +-
.../Errors/IneligibleReplicaException.cs | 2 +-
.../Kafka/Common/Errors/InterruptException.cs | 2 +-
.../InvalidCommitOffsetSizeException.cs | 2 +-
.../Errors/InvalidConfigurationException.cs | 2 +-
.../InvalidFetchSessionEpochException.cs | 2 +-
.../Errors/InvalidFetchSizeException.cs | 2 +-
.../Common/Errors/InvalidGroupIdException.cs | 2 +-
.../Common/Errors/InvalidMetadataException.cs | 2 +-
.../Common/Errors/InvalidOffsetException.cs | 2 +-
.../Errors/InvalidPartitionsException.cs | 2 +-
.../Errors/InvalidPidMappingException.cs | 2 +-
.../Errors/InvalidPrincipalTypeException.cs | 2 +-
.../Errors/InvalidProducerEpochException.cs | 2 +-
.../InvalidReplicaAssignmentException.cs | 2 +-
.../InvalidReplicationFactorException.cs | 2 +-
.../Common/Errors/InvalidRequestException.cs | 2 +-
.../Errors/InvalidRequiredAcksException.cs | 2 +-
.../Errors/InvalidSessionTimeoutException.cs | 2 +-
.../Errors/InvalidTimestampException.cs | 2 +-
.../Common/Errors/InvalidTopicException.cs | 2 +-
.../Common/Errors/InvalidTxnStateException.cs | 2 +-
.../Errors/InvalidTxnTimeoutException.cs | 2 +-
.../Errors/InvalidUpdateVersionException.cs | 2 +-
.../Common/Errors/KafkaStorageException.cs | 2 +-
.../Errors/LeaderNotAvailableException.cs | 2 +-
.../Errors/ListenerNotFoundException.cs | 2 +-
.../Common/Errors/LogDirNotFoundException.cs | 2 +-
.../Errors/MemberIdRequiredException.cs | 2 +-
.../Kafka/Common/Errors/NetworkException.cs | 2 +-
.../Errors/NewLeaderElectedException.cs | 2 +-
.../NoReassignmentInProgressException.cs | 2 +-
.../Common/Errors/NotControllerException.cs | 2 +-
.../Common/Errors/NotCoordinatorException.cs | 2 +-
.../NotEnoughReplicasAfterAppendException.cs | 2 +-
.../Errors/NotEnoughReplicasException.cs | 2 +-
.../Errors/NotLeaderOrFollowerException.cs | 2 +-
.../Common/Errors/OffsetMetadataTooLarge.cs | 2 +-
.../OffsetMovedToTieredStorageException.cs | 2 +-
.../Errors/OffsetNotAvailableException.cs | 2 +-
.../Errors/OffsetOutOfRangeException.cs | 2 +-
.../Errors/OperationNotAttemptedException.cs | 2 +-
.../Errors/OutOfOrderSequenceException.cs | 2 +-
.../Common/Errors/PolicyViolationException.cs | 2 +-
.../Errors/PositionOutOfRangeException.cs | 2 +-
.../PreferredLeaderNotAvailableException.cs | 2 +-
.../PrincipalDeserializationException.cs | 2 +-
.../Common/Errors/ProducerFencedException.cs | 2 +-
.../Errors/ReassignmentInProgressException.cs | 2 +-
.../Errors/RebalanceInProgressException.cs | 2 +-
.../Errors/RecordBatchTooLargeException.cs | 2 +-
.../Errors/RecordDeserializationException.cs | 2 +-
.../Common/Errors/RecordTooLargeException.cs | 2 +-
.../Errors/ReplicaNotAvailableException.cs | 2 +-
.../Errors/ResourceNotFoundException.cs | 2 +-
.../Kafka/Common/Errors/RetriableException.cs | 2 +-
.../Errors/SaslAuthenticationException.cs | 2 +-
.../Errors/SecurityDisabledException.cs | 2 +-
.../Common/Errors/SerializationException.cs | 2 +-
.../Errors/SnapshotNotFoundException.cs | 2 +-
.../Errors/SslAuthenticationException.cs | 2 +-
.../Errors/StaleBrokerEpochException.cs | 2 +-
.../Errors/StaleMemberEpochException.cs | 2 +-
.../ThrottlingQuotaExceededException.cs | 2 +-
.../Kafka/Common/Errors/TimeoutException.cs | 2 +-
.../Errors/TopicAuthorizationException.cs | 2 +-
.../Errors/TopicDeletionDisabledException.cs | 2 +-
.../Common/Errors/TopicExistsException.cs | 2 +-
.../Errors/TransactionAbortedException.cs | 2 +-
.../TransactionCoordinatorFencedException.cs | 2 +-
.../TransactionalIdAuthorizationException.cs | 2 +-
.../TransactionalIdNotFoundException.cs | 2 +-
.../Errors/UnacceptableCredentialException.cs | 2 +-
.../Errors/UnknownLeaderEpochException.cs | 2 +-
.../Common/Errors/UnknownMemberIdException.cs | 2 +-
.../Errors/UnknownProducerIdException.cs | 2 +-
.../Common/Errors/UnknownServerException.cs | 2 +-
.../Common/Errors/UnknownTopicIdException.cs | 2 +-
.../UnknownTopicOrPartitionException.cs | 2 +-
.../Errors/UnreleasedInstanceIdException.cs | 2 +-
.../Errors/UnstableOffsetCommitException.cs | 2 +-
.../Errors/UnsupportedAssignorException.cs | 2 +-
.../UnsupportedByAuthenticationException.cs | 2 +-
.../UnsupportedCompressionTypeException.cs | 2 +-
.../UnsupportedForMessageFormatException.cs | 2 +-
.../UnsupportedSaslMechanismException.cs | 2 +-
.../Errors/UnsupportedVersionException.cs | 2 +-
.../Kafka/Common/Errors/WakeupException.cs | 2 +-
.../Kafka/Common/Header/AllPackageClasses.cs | 2 +-
.../Org/Apache/Kafka/Common/Header/Header.cs | 6 +-
.../Org/Apache/Kafka/Common/Header/Headers.cs | 12 +-
.../Kafka/Common/InvalidRecordException.cs | 2 +-
.../Org/Apache/Kafka/Common/IsolationLevel.cs | 10 +-
.../Org/Apache/Kafka/Common/KafkaException.cs | 2 +-
.../Org/Apache/Kafka/Common/KafkaFuture.cs | 50 ++---
.../Kafka/Common/Memory/AllPackageClasses.cs | 2 +-
.../Memory/GarbageCollectedMemoryPool.cs | 4 +-
.../Apache/Kafka/Common/Memory/MemoryPool.cs | 12 +-
.../Kafka/Common/Memory/SimpleMemoryPool.cs | 12 +-
.../Apache/Kafka/Common/MessageFormatter.cs | 6 +-
.../Org/Apache/Kafka/Common/Metric.cs | 6 +-
.../Org/Apache/Kafka/Common/MetricName.cs | 10 +-
.../Apache/Kafka/Common/MetricNameTemplate.cs | 10 +-
.../Kafka/Common/Metrics/AllPackageClasses.cs | 2 +-
.../Kafka/Common/Metrics/CompoundStat.cs | 8 +-
.../Org/Apache/Kafka/Common/Metrics/Gauge.cs | 2 +-
.../Kafka/Common/Metrics/JmxReporter.cs | 24 +--
.../Kafka/Common/Metrics/KafkaMetric.cs | 12 +-
.../Common/Metrics/KafkaMetricsContext.cs | 4 +-
.../Apache/Kafka/Common/Metrics/Measurable.cs | 2 +-
.../Kafka/Common/Metrics/MeasurableStat.cs | 2 +-
.../Kafka/Common/Metrics/MetricConfig.cs | 24 +--
.../Common/Metrics/MetricValueProvider.cs | 2 +-
.../Apache/Kafka/Common/Metrics/Metrics.cs | 24 +--
.../Kafka/Common/Metrics/MetricsContext.cs | 4 +-
.../Kafka/Common/Metrics/MetricsReporter.cs | 10 +-
.../Org/Apache/Kafka/Common/Metrics/Quota.cs | 12 +-
.../Common/Metrics/QuotaViolationException.cs | 2 +-
.../Org/Apache/Kafka/Common/Metrics/Sensor.cs | 30 +--
.../Org/Apache/Kafka/Common/Metrics/Stat.cs | 2 +-
.../Common/Metrics/Stats/AllPackageClasses.cs | 2 +-
.../Apache/Kafka/Common/Metrics/Stats/Avg.cs | 2 +-
.../Common/Metrics/Stats/CumulativeCount.cs | 2 +-
.../Common/Metrics/Stats/CumulativeSum.cs | 2 +-
.../Kafka/Common/Metrics/Stats/Frequencies.cs | 4 +-
.../Kafka/Common/Metrics/Stats/Frequency.cs | 6 +-
.../Kafka/Common/Metrics/Stats/Histogram.cs | 28 +--
.../Apache/Kafka/Common/Metrics/Stats/Max.cs | 2 +-
.../Kafka/Common/Metrics/Stats/Meter.cs | 4 +-
.../Apache/Kafka/Common/Metrics/Stats/Min.cs | 2 +-
.../Kafka/Common/Metrics/Stats/Percentile.cs | 6 +-
.../Kafka/Common/Metrics/Stats/Percentiles.cs | 8 +-
.../Apache/Kafka/Common/Metrics/Stats/Rate.cs | 4 +-
.../Kafka/Common/Metrics/Stats/SampledStat.cs | 2 +-
.../Kafka/Common/Metrics/Stats/SimpleRate.cs | 2 +-
.../Kafka/Common/Metrics/Stats/TokenBucket.cs | 2 +-
.../Kafka/Common/Metrics/Stats/Value.cs | 2 +-
.../Common/Metrics/Stats/WindowedCount.cs | 2 +-
.../Kafka/Common/Metrics/Stats/WindowedSum.cs | 2 +-
.../Generated/Org/Apache/Kafka/Common/Node.cs | 18 +-
.../Org/Apache/Kafka/Common/PartitionInfo.cs | 14 +-
.../Kafka/Common/Quota/AllPackageClasses.cs | 2 +-
.../Common/Quota/ClientQuotaAlteration.cs | 10 +-
.../Kafka/Common/Quota/ClientQuotaEntity.cs | 6 +-
.../Kafka/Common/Quota/ClientQuotaFilter.cs | 12 +-
.../Quota/ClientQuotaFilterComponent.cs | 10 +-
.../Org/Apache/Kafka/Common/Reconfigurable.cs | 8 +-
.../Record/AbstractLegacyRecordBatch.cs | 26 +--
.../Kafka/Common/Record/AllPackageClasses.cs | 2 +-
.../Kafka/Common/Record/CompressionType.cs | 12 +-
.../Kafka/Common/Record/ControlRecordType.cs | 14 +-
.../Kafka/Common/Record/ControlRecordUtils.cs | 2 +-
.../Kafka/Common/Record/DefaultRecordBatch.cs | 16 +-
.../Kafka/Common/Record/FileLogInputStream.cs | 6 +-
.../Record/LazyDownConversionRecords.cs | 6 +-
.../Kafka/Common/Record/LegacyRecord.cs | 40 ++--
.../Common/Record/MemoryRecordsBuilder.cs | 52 ++---
.../Kafka/Common/Record/MultiRecordsSend.cs | 8 +-
.../Kafka/Common/Record/MutableRecordBatch.cs | 10 +-
.../Org/Apache/Kafka/Common/Record/Record.cs | 32 +--
.../Apache/Kafka/Common/Record/RecordBatch.cs | 50 ++---
.../Common/Record/RecordConversionStats.cs | 10 +-
.../Kafka/Common/Record/RecordVersion.cs | 12 +-
.../Apache/Kafka/Common/Record/RecordsUtil.cs | 2 +-
.../Common/Record/RemoteLogInputStream.cs | 4 +-
.../Kafka/Common/Record/SimpleRecord.cs | 10 +-
.../Kafka/Common/Record/TimestampType.cs | 8 +-
.../Common/Record/TransferableRecords.cs | 2 +-
.../Common/Record/UnalignedFileRecords.cs | 4 +-
.../Common/Record/UnalignedMemoryRecords.cs | 6 +-
.../Kafka/Common/Record/UnalignedRecords.cs | 2 +-
.../Kafka/Common/Replica/AllPackageClasses.cs | 2 +-
.../Kafka/Common/Replica/ClientMetadata.cs | 22 +--
.../Kafka/Common/Replica/PartitionView.cs | 10 +-
.../Replica/RackAwareReplicaSelector.cs | 2 +-
.../Kafka/Common/Replica/ReplicaSelector.cs | 6 +-
.../Kafka/Common/Replica/ReplicaView.cs | 16 +-
.../Common/Resource/AllPackageClasses.cs | 2 +-
.../Kafka/Common/Resource/PatternType.cs | 16 +-
.../Apache/Kafka/Common/Resource/Resource.cs | 8 +-
.../Kafka/Common/Resource/ResourcePattern.cs | 12 +-
.../Common/Resource/ResourcePatternFilter.cs | 16 +-
.../Kafka/Common/Resource/ResourceType.cs | 14 +-
.../Common/Security/AllPackageClasses.cs | 2 +-
.../Common/Security/Auth/AllPackageClasses.cs | 2 +-
.../Auth/AuthenticateCallbackHandler.cs | 4 +-
.../Security/Auth/AuthenticationContext.cs | 8 +-
.../Common/Security/Auth/KafkaPrincipal.cs | 10 +-
.../Security/Auth/KafkaPrincipalBuilder.cs | 4 +-
.../Security/Auth/KafkaPrincipalSerde.cs | 6 +-
.../Kafka/Common/Security/Auth/Login.cs | 10 +-
.../Auth/PlaintextAuthenticationContext.cs | 8 +-
.../Auth/SaslAuthenticationContext.cs | 12 +-
.../Common/Security/Auth/SaslExtensions.cs | 6 +-
.../Security/Auth/SaslExtensionsCallback.cs | 6 +-
.../Common/Security/Auth/SecurityProtocol.cs | 12 +-
.../Security/Auth/SecurityProviderCreator.cs | 6 +-
.../Security/Auth/SslAuthenticationContext.cs | 10 +-
.../Common/Security/Auth/SslEngineFactory.cs | 10 +-
.../Security/Authenticator/AbstractLogin.cs | 10 +-
.../Authenticator/AllPackageClasses.cs | 2 +-
.../Security/Authenticator/CredentialCache.cs | 14 +-
.../DefaultKafkaPrincipalBuilder.cs | 8 +-
.../Security/Authenticator/DefaultLogin.cs | 2 +-
.../Security/Authenticator/LoginManager.cs | 10 +-
.../Authenticator/SaslClientAuthenticator.cs | 24 +--
.../SaslClientCallbackHandler.cs | 6 +-
.../Authenticator/SaslInternalConfigs.cs | 2 +-
.../Authenticator/SaslServerAuthenticator.cs | 20 +-
.../SaslServerCallbackHandler.cs | 6 +-
.../Kafka/Common/Security/JaasContext.cs | 18 +-
.../Apache/Kafka/Common/Security/JaasUtils.cs | 6 +-
.../Security/Oauthbearer/AllPackageClasses.cs | 2 +-
.../OAuthBearerExtensionsValidatorCallback.cs | 14 +-
.../OAuthBearerLoginCallbackHandler.cs | 6 +-
.../Oauthbearer/OAuthBearerLoginModule.cs | 10 +-
.../Security/Oauthbearer/OAuthBearerToken.cs | 12 +-
.../Oauthbearer/OAuthBearerTokenCallback.cs | 12 +-
.../OAuthBearerValidatorCallback.cs | 14 +-
.../OAuthBearerValidatorCallbackHandler.cs | 6 +-
.../Oauthbearer/Secured/AllPackageClasses.cs | 2 +-
.../Security/Plain/AllPackageClasses.cs | 2 +-
.../Plain/Internals/AllPackageClasses.cs | 2 +-
.../Plain/Internals/PlainSaslServer.cs | 16 +-
.../Internals/PlainSaslServerProvider.cs | 4 +-
.../Internals/PlainServerCallbackHandler.cs | 6 +-
.../Plain/PlainAuthenticateCallback.cs | 8 +-
.../Common/Security/Plain/PlainLoginModule.cs | 10 +-
.../Security/Scram/AllPackageClasses.cs | 2 +-
.../Common/Security/Scram/ScramCredential.cs | 10 +-
.../Security/Scram/ScramCredentialCallback.cs | 6 +-
.../Security/Scram/ScramExtensionsCallback.cs | 6 +-
.../Common/Security/Scram/ScramLoginModule.cs | 10 +-
.../Common/Security/Ssl/AllPackageClasses.cs | 2 +-
.../Security/Ssl/DefaultSslEngineFactory.cs | 16 +-
.../Kafka/Common/Security/Ssl/SslFactory.cs | 16 +-
.../Common/Security/Ssl/SslPrincipalMapper.cs | 6 +-
.../Token/Delegation/AllPackageClasses.cs | 2 +-
.../Token/Delegation/DelegationToken.cs | 8 +-
.../Token/Delegation/TokenInformation.cs | 26 +--
.../Common/Serialization/AllPackageClasses.cs | 2 +-
.../Serialization/BooleanDeserializer.cs | 2 +-
.../Common/Serialization/BooleanSerializer.cs | 2 +-
.../Serialization/ByteArrayDeserializer.cs | 2 +-
.../Serialization/ByteArraySerializer.cs | 2 +-
.../Serialization/ByteBufferDeserializer.cs | 2 +-
.../Serialization/ByteBufferSerializer.cs | 2 +-
.../Common/Serialization/BytesDeserializer.cs | 2 +-
.../Common/Serialization/BytesSerializer.cs | 2 +-
.../Common/Serialization/Deserializer.cs | 6 +-
.../Serialization/DoubleDeserializer.cs | 2 +-
.../Common/Serialization/DoubleSerializer.cs | 2 +-
.../Common/Serialization/FloatDeserializer.cs | 2 +-
.../Common/Serialization/FloatSerializer.cs | 2 +-
.../Serialization/IntegerDeserializer.cs | 2 +-
.../Common/Serialization/IntegerSerializer.cs | 2 +-
.../Common/Serialization/ListDeserializer.cs | 10 +-
.../Common/Serialization/ListSerializer.cs | 10 +-
.../Common/Serialization/LongDeserializer.cs | 2 +-
.../Common/Serialization/LongSerializer.cs | 2 +-
.../Kafka/Common/Serialization/Serde.cs | 6 +-
.../Kafka/Common/Serialization/Serdes.cs | 40 ++--
.../Kafka/Common/Serialization/Serializer.cs | 6 +-
.../Common/Serialization/ShortDeserializer.cs | 2 +-
.../Common/Serialization/ShortSerializer.cs | 2 +-
.../Serialization/StringDeserializer.cs | 2 +-
.../Common/Serialization/StringSerializer.cs | 2 +-
.../Common/Serialization/UUIDDeserializer.cs | 2 +-
.../Common/Serialization/UUIDSerializer.cs | 2 +-
.../Common/Serialization/VoidDeserializer.cs | 2 +-
.../Apache/Kafka/Common/TopicCollection.cs | 10 +-
.../Apache/Kafka/Common/TopicIdPartition.cs | 10 +-
.../Org/Apache/Kafka/Common/TopicPartition.cs | 6 +-
.../Apache/Kafka/Common/TopicPartitionInfo.cs | 10 +-
.../Kafka/Common/TopicPartitionReplica.cs | 8 +-
.../Kafka/Common/Utils/AbstractIterator.cs | 18 +-
.../Kafka/Common/Utils/AllPackageClasses.cs | 2 +-
.../Kafka/Common/Utils/AppInfoParser.cs | 18 +-
.../Kafka/Common/Utils/BufferSupplier.cs | 10 +-
.../Common/Utils/ByteBufferInputStream.cs | 2 +-
.../Common/Utils/ByteBufferOutputStream.cs | 18 +-
.../Kafka/Common/Utils/ByteBufferUnmapper.cs | 2 +-
.../Apache/Kafka/Common/Utils/ByteUtils.cs | 28 +--
.../Org/Apache/Kafka/Common/Utils/Bytes.cs | 12 +-
.../Apache/Kafka/Common/Utils/Checksums.cs | 2 +-
.../Common/Utils/ChildFirstClassLoader.cs | 2 +-
.../Kafka/Common/Utils/ChunkedBytesStream.cs | 4 +-
.../Kafka/Common/Utils/CircularIterator.cs | 18 +-
.../Kafka/Common/Utils/CloseableIterator.cs | 10 +-
.../Kafka/Common/Utils/CollectionUtils.cs | 6 +-
.../Apache/Kafka/Common/Utils/ConfigUtils.cs | 2 +-
.../Kafka/Common/Utils/CopyOnWriteMap.cs | 46 ++---
.../Org/Apache/Kafka/Common/Utils/Crc32C.cs | 4 +-
.../Org/Apache/Kafka/Common/Utils/Exit.cs | 18 +-
.../Kafka/Common/Utils/ExponentialBackoff.cs | 4 +-
.../Kafka/Common/Utils/FixedOrderMap.cs | 2 +-
.../Kafka/Common/Utils/FlattenedIterator.cs | 6 +-
.../Apache/Kafka/Common/Utils/KafkaThread.cs | 2 +-
.../Apache/Kafka/Common/Utils/LogContext.cs | 4 +-
.../Common/Utils/LoggingSignalHandler.cs | 4 +-
.../Kafka/Common/Utils/MappedIterator.cs | 10 +-
.../Kafka/Common/Utils/OperatingSystem.cs | 2 +-
.../Apache/Kafka/Common/Utils/PrimitiveRef.cs | 6 +-
.../Kafka/Common/Utils/ProducerIdAndEpoch.cs | 4 +-
.../Kafka/Common/Utils/PureJavaCrc32C.cs | 8 +-
.../Apache/Kafka/Common/Utils/Sanitizer.cs | 8 +-
.../Apache/Kafka/Common/Utils/Scheduler.cs | 4 +-
.../Kafka/Common/Utils/SecurityUtils.cs | 18 +-
.../Org/Apache/Kafka/Common/Utils/Shell.cs | 12 +-
.../Kafka/Common/Utils/SystemScheduler.cs | 4 +-
.../Apache/Kafka/Common/Utils/SystemTime.cs | 8 +-
.../Apache/Kafka/Common/Utils/ThreadUtils.cs | 2 +-
.../Org/Apache/Kafka/Common/Utils/Time.cs | 14 +-
.../Org/Apache/Kafka/Common/Utils/Timer.cs | 26 +--
.../Org/Apache/Kafka/Common/Utils/Utils.cs | 90 ++++-----
.../Generated/Org/Apache/Kafka/Common/Uuid.cs | 14 +-
.../Kafka/Connect/Cli/AllPackageClasses.cs | 2 +-
.../Kafka/Connect/Cli/ConnectDistributed.cs | 4 +-
.../Kafka/Connect/Cli/ConnectStandalone.cs | 4 +-
.../Connect/Components/AllPackageClasses.cs | 2 +-
.../Kafka/Connect/Components/Versioned.cs | 4 +-
.../Connect/Connector/AllPackageClasses.cs | 2 +-
.../Kafka/Connect/Connector/ConnectRecord.cs | 34 ++--
.../Kafka/Connect/Connector/Connector.cs | 18 +-
.../Connect/Connector/ConnectorContext.cs | 6 +-
.../Apache/Kafka/Connect/Connector/Task.cs | 8 +-
.../Connect/Converters/AllPackageClasses.cs | 2 +-
.../Connect/Converters/ByteArrayConverter.cs | 10 +-
.../Connect/Converters/DoubleConverter.cs | 2 +-
.../Connect/Converters/FloatConverter.cs | 2 +-
.../Connect/Converters/IntegerConverter.cs | 2 +-
.../Kafka/Connect/Converters/LongConverter.cs | 2 +-
.../Converters/NumberConverterConfig.cs | 4 +-
.../Connect/Converters/ShortConverter.cs | 2 +-
.../Kafka/Connect/Data/AllPackageClasses.cs | 2 +-
.../Kafka/Connect/Data/ConnectSchema.cs | 30 +--
.../Org/Apache/Kafka/Connect/Data/Date.cs | 4 +-
.../Org/Apache/Kafka/Connect/Data/Decimal.cs | 6 +-
.../Org/Apache/Kafka/Connect/Data/Field.cs | 8 +-
.../Org/Apache/Kafka/Connect/Data/Schema.cs | 34 ++--
.../Kafka/Connect/Data/SchemaAndValue.cs | 6 +-
.../Kafka/Connect/Data/SchemaBuilder.cs | 66 +++----
.../Kafka/Connect/Data/SchemaProjector.cs | 2 +-
.../Org/Apache/Kafka/Connect/Data/Struct.cs | 34 ++--
.../Org/Apache/Kafka/Connect/Data/Time.cs | 4 +-
.../Apache/Kafka/Connect/Data/Timestamp.cs | 4 +-
.../Org/Apache/Kafka/Connect/Data/Values.cs | 8 +-
.../Kafka/Connect/Errors/AllPackageClasses.cs | 2 +-
.../Connect/Errors/AlreadyExistsException.cs | 2 +-
.../Kafka/Connect/Errors/ConnectException.cs | 2 +-
.../Kafka/Connect/Errors/DataException.cs | 2 +-
.../Errors/IllegalWorkerStateException.cs | 2 +-
.../Kafka/Connect/Errors/NotFoundException.cs | 2 +-
.../Connect/Errors/RetriableException.cs | 2 +-
.../Connect/Errors/SchemaBuilderException.cs | 2 +-
.../Errors/SchemaProjectorException.cs | 2 +-
.../Kafka/Connect/Header/AllPackageClasses.cs | 2 +-
.../Kafka/Connect/Header/ConnectHeaders.cs | 26 +--
.../Org/Apache/Kafka/Connect/Header/Header.cs | 10 +-
.../Apache/Kafka/Connect/Header/Headers.cs | 26 +--
.../Kafka/Connect/Health/AbstractState.cs | 8 +-
.../Kafka/Connect/Health/AllPackageClasses.cs | 2 +-
.../Connect/Health/ConnectClusterDetails.cs | 4 +-
.../Connect/Health/ConnectClusterState.cs | 10 +-
.../Kafka/Connect/Health/ConnectorHealth.cs | 10 +-
.../Kafka/Connect/Health/ConnectorState.cs | 2 +-
.../Kafka/Connect/Health/ConnectorType.cs | 6 +-
.../Apache/Kafka/Connect/Health/TaskState.cs | 4 +-
.../Kafka/Connect/Json/AllPackageClasses.cs | 2 +-
.../Kafka/Connect/Json/DecimalFormat.cs | 6 +-
.../Kafka/Connect/Json/JsonConverter.cs | 10 +-
.../Kafka/Connect/Json/JsonConverterConfig.cs | 12 +-
.../Kafka/Connect/Json/JsonDeserializer.cs | 2 +-
.../Apache/Kafka/Connect/Json/JsonSchema.cs | 2 +-
.../Kafka/Connect/Json/JsonSerializer.cs | 2 +-
.../Kafka/Connect/Mirror/AllPackageClasses.cs | 2 +-
.../Apache/Kafka/Connect/Mirror/Checkpoint.cs | 16 +-
.../Connect/Mirror/ConfigPropertyFilter.cs | 10 +-
.../Mirror/DefaultConfigPropertyFilter.cs | 8 +-
.../Connect/Mirror/DefaultGroupFilter.cs | 6 +-
.../Mirror/DefaultReplicationPolicy.cs | 16 +-
.../Connect/Mirror/DefaultTopicFilter.cs | 6 +-
.../Mirror/Formatters/AllPackageClasses.cs | 2 +-
.../Mirror/Formatters/CheckpointFormatter.cs | 2 +-
.../Mirror/Formatters/HeartbeatFormatter.cs | 2 +-
.../Mirror/Formatters/OffsetSyncFormatter.cs | 2 +-
.../Kafka/Connect/Mirror/GroupFilter.cs | 8 +-
.../Apache/Kafka/Connect/Mirror/Heartbeat.cs | 10 +-
.../Mirror/IdentityReplicationPolicy.cs | 2 +-
.../Connect/Mirror/MirrorCheckpointConfig.cs | 2 +-
.../Mirror/MirrorCheckpointConnector.cs | 2 +-
.../Connect/Mirror/MirrorCheckpointTask.cs | 2 +-
.../Mirror/MirrorCheckpointTaskConfig.cs | 2 +-
.../Kafka/Connect/Mirror/MirrorClient.cs | 18 +-
.../Connect/Mirror/MirrorClientConfig.cs | 10 +-
.../Connect/Mirror/MirrorConnectorConfig.cs | 4 +-
.../Connect/Mirror/MirrorHeartbeatConfig.cs | 2 +-
.../Mirror/MirrorHeartbeatConnector.cs | 2 +-
.../Connect/Mirror/MirrorHeartbeatTask.cs | 2 +-
.../Kafka/Connect/Mirror/MirrorMaker.cs | 10 +-
.../Kafka/Connect/Mirror/MirrorMakerConfig.cs | 12 +-
.../Connect/Mirror/MirrorSourceConfig.cs | 2 +-
.../Connect/Mirror/MirrorSourceConnector.cs | 2 +-
.../Kafka/Connect/Mirror/MirrorSourceTask.cs | 2 +-
.../Connect/Mirror/MirrorSourceTaskConfig.cs | 2 +-
.../Kafka/Connect/Mirror/MirrorUtils.cs | 6 +-
.../Apache/Kafka/Connect/Mirror/OffsetSync.cs | 10 +-
.../Connect/Mirror/RemoteClusterUtils.cs | 8 +-
.../Kafka/Connect/Mirror/ReplicationPolicy.cs | 22 +--
.../Kafka/Connect/Mirror/SourceAndTarget.cs | 6 +-
.../Kafka/Connect/Mirror/TopicFilter.cs | 8 +-
.../Kafka/Connect/Rest/AllPackageClasses.cs | 2 +-
.../Basic/Auth/Extension/AllPackageClasses.cs | 2 +-
.../BasicAuthSecurityRestExtension.cs | 8 +-
.../Auth/Extension/JaasBasicAuthFilter.cs | 4 +-
.../Auth/Extension/PropertyFileLoginModule.cs | 10 +-
.../Kafka/Connect/Sink/AllPackageClasses.cs | 2 +-
.../Connect/Sink/ErrantRecordReporter.cs | 2 +-
.../Kafka/Connect/Sink/SinkConnector.cs | 2 +-
.../Connect/Sink/SinkConnectorContext.cs | 2 +-
.../Apache/Kafka/Connect/Sink/SinkRecord.cs | 12 +-
.../Org/Apache/Kafka/Connect/Sink/SinkTask.cs | 18 +-
.../Kafka/Connect/Sink/SinkTaskContext.cs | 18 +-
.../Kafka/Connect/Source/AllPackageClasses.cs | 2 +-
.../Source/ConnectorTransactionBoundaries.cs | 6 +-
.../Connect/Source/ExactlyOnceSupport.cs | 6 +-
.../Kafka/Connect/Source/SourceConnector.cs | 6 +-
.../Connect/Source/SourceConnectorContext.cs | 2 +-
.../Kafka/Connect/Source/SourceRecord.cs | 6 +-
.../Apache/Kafka/Connect/Source/SourceTask.cs | 18 +-
.../Kafka/Connect/Source/SourceTaskContext.cs | 6 +-
.../Connect/Source/TransactionContext.cs | 10 +-
.../Connect/Transforms/AllPackageClasses.cs | 2 +-
.../Apache/Kafka/Connect/Transforms/Cast.cs | 22 +--
.../Kafka/Connect/Transforms/DropHeaders.cs | 22 +--
.../Kafka/Connect/Transforms/ExtractField.cs | 22 +--
.../Apache/Kafka/Connect/Transforms/Filter.cs | 22 +--
.../Kafka/Connect/Transforms/Flatten.cs | 22 +--
.../Kafka/Connect/Transforms/HeaderFrom.cs | 30 +--
.../Kafka/Connect/Transforms/HoistField.cs | 22 +--
.../Kafka/Connect/Transforms/InsertField.cs | 22 +--
.../Kafka/Connect/Transforms/InsertHeader.cs | 22 +--
.../Kafka/Connect/Transforms/MaskField.cs | 22 +--
.../Predicates/AllPackageClasses.cs | 2 +-
.../Transforms/Predicates/HasHeaderKey.cs | 22 +--
.../Transforms/Predicates/Predicate.cs | 14 +-
.../Predicates/RecordIsTombstone.cs | 22 +--
.../Transforms/Predicates/TopicNameMatches.cs | 22 +--
.../Kafka/Connect/Transforms/RegexRouter.cs | 22 +--
.../Kafka/Connect/Transforms/ReplaceField.cs | 22 +--
.../Connect/Transforms/SetSchemaMetadata.cs | 22 +--
.../Connect/Transforms/TimestampConverter.cs | 22 +--
.../Connect/Transforms/TimestampRouter.cs | 22 +--
.../Connect/Transforms/Transformation.cs | 14 +-
.../Transforms/Util/AllPackageClasses.cs | 2 +-
.../Transforms/Util/NonEmptyListValidator.cs | 2 +-
.../Connect/Transforms/Util/RegexValidator.cs | 2 +-
.../Connect/Transforms/Util/Requirements.cs | 2 +-
.../Connect/Transforms/Util/SchemaUtil.cs | 4 +-
.../Connect/Transforms/Util/SimpleConfig.cs | 2 +-
.../Kafka/Connect/Transforms/ValueToKey.cs | 22 +--
.../Kafka/Connect/Util/AllPackageClasses.cs | 2 +-
.../Org/Apache/Kafka/Connect/Util/Callback.cs | 2 +-
.../Apache/Kafka/Connect/Util/ConnectUtils.cs | 10 +-
.../Kafka/Connect/Util/ConnectorTaskId.cs | 10 +-
.../Kafka/Connect/Util/ConnectorUtils.cs | 2 +-
.../Connect/Util/ConvertingFutureCallback.cs | 22 +--
.../Kafka/Connect/Util/FutureCallback.cs | 2 +-
.../Kafka/Connect/Util/KafkaBasedLog.cs | 26 +--
.../Kafka/Connect/Util/LoggingContext.cs | 18 +-
.../Apache/Kafka/Connect/Util/RetryUtil.cs | 2 +-
.../Connect/Util/SafeObjectInputStream.cs | 2 +-
.../Apache/Kafka/Connect/Util/SinkUtils.cs | 6 +-
.../Org/Apache/Kafka/Connect/Util/Table.cs | 14 +-
.../Apache/Kafka/Connect/Util/TopicAdmin.cs | 62 +++---
.../Kafka/Connect/Util/TopicCreation.cs | 16 +-
.../Kafka/Connect/Util/TopicCreationGroup.cs | 8 +-
.../Apache/Kafka/Raft/AllPackageClasses.cs | 2 +-
.../Generated/Org/Apache/Kafka/Raft/Batch.cs | 34 ++--
.../Org/Apache/Kafka/Raft/BatchReader.cs | 14 +-
.../Org/Apache/Kafka/Raft/CandidateState.cs | 42 ++--
.../Org/Apache/Kafka/Raft/ControlRecord.cs | 6 +-
.../Org/Apache/Kafka/Raft/ElectionState.cs | 18 +-
.../Org/Apache/Kafka/Raft/EpochState.cs | 10 +-
.../Kafka/Raft/Errors/AllPackageClasses.cs | 2 +-
.../Raft/Errors/BufferAllocationException.cs | 2 +-
.../Kafka/Raft/Errors/NotLeaderException.cs | 2 +-
.../Apache/Kafka/Raft/Errors/RaftException.cs | 2 +-
.../Errors/UnexpectedBaseOffsetException.cs | 2 +-
.../Apache/Kafka/Raft/ExpirationService.cs | 4 +-
.../Apache/Kafka/Raft/FileBasedStateStore.cs | 8 +-
.../Org/Apache/Kafka/Raft/FollowerState.cs | 26 +--
.../Kafka/Raft/Generated/AllPackageClasses.cs | 2 +-
.../Kafka/Raft/Generated/QuorumStateData.cs | 40 ++--
.../Generated/QuorumStateDataJsonConverter.cs | 2 +-
.../Org/Apache/Kafka/Raft/Isolation.cs | 6 +-
.../Org/Apache/Kafka/Raft/KafkaRaftClient.cs | 62 +++---
.../Org/Apache/Kafka/Raft/LeaderAndEpoch.cs | 8 +-
.../Org/Apache/Kafka/Raft/LeaderState.cs | 62 +++---
.../Org/Apache/Kafka/Raft/LogAppendInfo.cs | 2 +-
.../Org/Apache/Kafka/Raft/LogFetchInfo.cs | 2 +-
.../Apache/Kafka/Raft/LogOffsetMetadata.cs | 2 +-
.../Org/Apache/Kafka/Raft/NetworkChannel.cs | 8 +-
.../Org/Apache/Kafka/Raft/OffsetAndEpoch.cs | 10 +-
.../Org/Apache/Kafka/Raft/OffsetMetadata.cs | 2 +-
.../Org/Apache/Kafka/Raft/QuorumState.cs | 64 +++---
.../Org/Apache/Kafka/Raft/QuorumStateStore.cs | 8 +-
.../Org/Apache/Kafka/Raft/RaftClient.cs | 50 ++---
.../Org/Apache/Kafka/Raft/RaftConfig.cs | 24 +--
.../Org/Apache/Kafka/Raft/RaftMessage.cs | 4 +-
.../Org/Apache/Kafka/Raft/RaftMessageQueue.cs | 10 +-
.../Org/Apache/Kafka/Raft/RaftRequest.cs | 8 +-
.../Org/Apache/Kafka/Raft/RaftResponse.cs | 6 +-
.../Org/Apache/Kafka/Raft/RaftUtil.cs | 2 +-
.../Apache/Kafka/Raft/ReplicatedCounter.cs | 14 +-
.../Org/Apache/Kafka/Raft/ReplicatedLog.cs | 48 ++---
.../Org/Apache/Kafka/Raft/RequestManager.cs | 12 +-
.../Org/Apache/Kafka/Raft/ResignedState.cs | 20 +-
.../Org/Apache/Kafka/Raft/UnattachedState.cs | 18 +-
.../Apache/Kafka/Raft/ValidOffsetAndEpoch.cs | 18 +-
.../Org/Apache/Kafka/Raft/VotedState.cs | 18 +-
.../Kafka/Snapshot/AllPackageClasses.cs | 2 +-
.../Kafka/Snapshot/FileRawSnapshotReader.cs | 8 +-
.../Kafka/Snapshot/FileRawSnapshotWriter.cs | 14 +-
.../Kafka/Snapshot/RawSnapshotReader.cs | 6 +-
.../Kafka/Snapshot/RawSnapshotWriter.cs | 14 +-
.../Kafka/Snapshot/RecordsSnapshotReader.cs | 30 +--
.../Kafka/Snapshot/RecordsSnapshotWriter.cs | 30 +--
.../Org/Apache/Kafka/Snapshot/SnapshotPath.cs | 2 +-
.../Apache/Kafka/Snapshot/SnapshotReader.cs | 22 +--
.../Apache/Kafka/Snapshot/SnapshotWriter.cs | 30 +--
.../Org/Apache/Kafka/Snapshot/Snapshots.cs | 8 +-
.../Apache/Kafka/Streams/AllPackageClasses.cs | 2 +-
.../Kafka/Streams/Errors/AllPackageClasses.cs | 2 +-
.../Streams/Errors/BrokerNotFoundException.cs | 2 +-
.../DefaultProductionExceptionHandler.cs | 4 +-
.../Errors/DeserializationExceptionHandler.cs | 6 +-
.../Errors/InvalidStateStoreException.cs | 2 +-
.../InvalidStateStorePartitionException.cs | 2 +-
.../Kafka/Streams/Errors/LockException.cs | 2 +-
.../Errors/LogAndContinueExceptionHandler.cs | 4 +-
.../Errors/LogAndFailExceptionHandler.cs | 4 +-
.../Errors/MissingSourceTopicException.cs | 2 +-
.../Streams/Errors/ProcessorStateException.cs | 2 +-
.../Errors/ProductionExceptionHandler.cs | 6 +-
.../Errors/StateStoreMigratedException.cs | 2 +-
.../Errors/StateStoreNotAvailableException.cs | 2 +-
.../Kafka/Streams/Errors/StreamsException.cs | 2 +-
.../Errors/StreamsNotStartedException.cs | 2 +-
.../Errors/StreamsRebalancingException.cs | 2 +-
.../Streams/Errors/StreamsStoppedException.cs | 2 +-
.../Errors/StreamsUncaughtExceptionHandler.cs | 6 +-
.../Streams/Errors/TaskAssignmentException.cs | 2 +-
.../Streams/Errors/TaskCorruptedException.cs | 2 +-
.../Streams/Errors/TaskIdFormatException.cs | 2 +-
.../Streams/Errors/TaskMigratedException.cs | 2 +-
.../Kafka/Streams/Errors/TopologyException.cs | 2 +-
.../Errors/UnknownStateStoreException.cs | 2 +-
.../Errors/UnknownTopologyException.cs | 2 +-
.../Kafka/Streams/KafkaClientSupplier.cs | 4 +-
.../Org/Apache/Kafka/Streams/KafkaStreams.cs | 66 +++----
.../Apache/Kafka/Streams/KeyQueryMetadata.cs | 8 +-
.../Org/Apache/Kafka/Streams/KeyValue.cs | 2 +-
.../Kafka/Streams/Kstream/Aggregator.cs | 2 +-
.../Streams/Kstream/AllPackageClasses.cs | 2 +-
.../Apache/Kafka/Streams/Kstream/Branched.cs | 2 +-
.../Kafka/Streams/Kstream/BranchedKStream.cs | 18 +-
.../Kafka/Streams/Kstream/CogroupedKStream.cs | 14 +-
.../Apache/Kafka/Streams/Kstream/Consumed.cs | 18 +-
.../Kafka/Streams/Kstream/EmitStrategy.cs | 14 +-
.../Kafka/Streams/Kstream/ForeachAction.cs | 2 +-
.../Kafka/Streams/Kstream/ForeachProcessor.cs | 6 +-
.../Kafka/Streams/Kstream/GlobalKTable.cs | 6 +-
.../Apache/Kafka/Streams/Kstream/Grouped.cs | 10 +-
.../Kafka/Streams/Kstream/Initializer.cs | 2 +-
.../Kafka/Streams/Kstream/JoinWindows.cs | 8 +-
.../Apache/Kafka/Streams/Kstream/Joined.cs | 34 ++--
.../Kafka/Streams/Kstream/KGroupedStream.cs | 30 +--
.../Kafka/Streams/Kstream/KGroupedTable.cs | 14 +-
.../Apache/Kafka/Streams/Kstream/KStream.cs | 94 ++++-----
.../Apache/Kafka/Streams/Kstream/KTable.cs | 38 ++--
.../Kafka/Streams/Kstream/KeyValueMapper.cs | 2 +-
.../Kafka/Streams/Kstream/Materialized.cs | 38 ++--
.../Apache/Kafka/Streams/Kstream/Merger.cs | 2 +-
.../Org/Apache/Kafka/Streams/Kstream/Named.cs | 4 +-
.../Apache/Kafka/Streams/Kstream/Predicate.cs | 2 +-
.../Apache/Kafka/Streams/Kstream/Printed.cs | 10 +-
.../Apache/Kafka/Streams/Kstream/Produced.cs | 14 +-
.../Apache/Kafka/Streams/Kstream/Reducer.cs | 2 +-
.../Kafka/Streams/Kstream/Repartitioned.cs | 18 +-
.../SessionWindowedCogroupedKStream.cs | 2 +-
.../Kstream/SessionWindowedDeserializer.cs | 6 +-
.../Streams/Kstream/SessionWindowedKStream.cs | 22 +--
.../Kstream/SessionWindowedSerializer.cs | 6 +-
.../Kafka/Streams/Kstream/SessionWindows.cs | 8 +-
.../Kafka/Streams/Kstream/SlidingWindows.cs | 8 +-
.../Kafka/Streams/Kstream/StreamJoined.cs | 34 ++--
.../Kafka/Streams/Kstream/Suppressed.cs | 46 ++---
.../Kafka/Streams/Kstream/TableJoined.cs | 10 +-
.../Kstream/TimeWindowedCogroupedKStream.cs | 6 +-
.../Kstream/TimeWindowedDeserializer.cs | 14 +-
.../Streams/Kstream/TimeWindowedKStream.cs | 22 +--
.../Streams/Kstream/TimeWindowedSerializer.cs | 6 +-
.../Kafka/Streams/Kstream/TimeWindows.cs | 6 +-
.../Kafka/Streams/Kstream/Transformer.cs | 2 +-
.../Kafka/Streams/Kstream/UnlimitedWindows.cs | 6 +-
.../Kafka/Streams/Kstream/ValueJoiner.cs | 2 +-
.../Streams/Kstream/ValueJoinerWithKey.cs | 2 +-
.../Kafka/Streams/Kstream/ValueMapper.cs | 2 +-
.../Streams/Kstream/ValueMapperWithKey.cs | 2 +-
.../Kafka/Streams/Kstream/ValueTransformer.cs | 2 +-
.../Kstream/ValueTransformerWithKey.cs | 2 +-
.../Apache/Kafka/Streams/Kstream/Window.cs | 12 +-
.../Apache/Kafka/Streams/Kstream/Windowed.cs | 10 +-
.../Kafka/Streams/Kstream/WindowedSerdes.cs | 8 +-
.../Apache/Kafka/Streams/Kstream/Windows.cs | 14 +-
.../Org/Apache/Kafka/Streams/LagInfo.cs | 8 +-
.../Streams/Processor/AllPackageClasses.cs | 2 +-
.../Processor/Api/AllPackageClasses.cs | 2 +-
.../Api/ContextualFixedKeyProcessor.cs | 6 +-
.../Processor/Api/ContextualProcessor.cs | 6 +-
.../Processor/Api/FixedKeyProcessor.cs | 10 +-
.../Processor/Api/FixedKeyProcessorContext.cs | 2 +-
.../Streams/Processor/Api/FixedKeyRecord.cs | 30 +--
.../Api/InternalFixedKeyRecordFactory.cs | 2 +-
.../Processor/Api/ProcessingContext.cs | 26 +--
.../Kafka/Streams/Processor/Api/Processor.cs | 10 +-
.../Streams/Processor/Api/ProcessorContext.cs | 2 +-
.../Kafka/Streams/Processor/Api/Record.cs | 34 ++--
.../Streams/Processor/Api/RecordMetadata.cs | 8 +-
.../Processor/BatchingStateRestoreCallback.cs | 2 +-
.../Kafka/Streams/Processor/Cancellable.cs | 4 +-
.../Kafka/Streams/Processor/CommitCallback.cs | 4 +-
.../Processor/ConnectedStoreProvider.cs | 4 +-
.../Processor/FailOnInvalidTimestamp.cs | 2 +-
.../Processor/LogAndSkipOnInvalidTimestamp.cs | 2 +-
.../Streams/Processor/ProcessorContext.cs | 34 ++--
.../Streams/Processor/PunctuationType.cs | 6 +-
.../Kafka/Streams/Processor/Punctuator.cs | 2 +-
.../Kafka/Streams/Processor/RecordContext.cs | 12 +-
.../Streams/Processor/StateRestoreCallback.cs | 2 +-
.../Streams/Processor/StateRestoreListener.cs | 2 +-
.../Kafka/Streams/Processor/StateStore.cs | 14 +-
.../Streams/Processor/StateStoreContext.cs | 20 +-
.../Streams/Processor/StreamPartitioner.cs | 2 +-
.../Apache/Kafka/Streams/Processor/TaskId.cs | 14 +-
.../Streams/Processor/TimestampExtractor.cs | 2 +-
.../Org/Apache/Kafka/Streams/Processor/To.cs | 8 +-
.../Streams/Processor/TopicNameExtractor.cs | 2 +-
.../UsePartitionTimeOnInvalidTimestamp.cs | 2 +-
.../Processor/WallclockTimestampExtractor.cs | 2 +-
.../Kafka/Streams/Query/AllPackageClasses.cs | 2 +-
.../Kafka/Streams/Query/FailureReason.cs | 6 +-
.../Apache/Kafka/Streams/Query/KeyQuery.cs | 14 +-
.../Apache/Kafka/Streams/Query/Position.cs | 16 +-
.../Kafka/Streams/Query/PositionBound.cs | 10 +-
.../Org/Apache/Kafka/Streams/Query/Query.cs | 2 +-
.../Apache/Kafka/Streams/Query/QueryConfig.cs | 4 +-
.../Apache/Kafka/Streams/Query/QueryResult.cs | 38 ++--
.../Apache/Kafka/Streams/Query/RangeQuery.cs | 10 +-
.../Kafka/Streams/Query/StateQueryRequest.cs | 56 +++---
.../Kafka/Streams/Query/StateQueryResult.cs | 18 +-
.../Kafka/Streams/Query/WindowKeyQuery.cs | 14 +-
.../Kafka/Streams/Query/WindowRangeQuery.cs | 14 +-
.../Kafka/Streams/State/AllPackageClasses.cs | 2 +-
.../Apache/Kafka/Streams/State/HostInfo.cs | 10 +-
.../State/KeyValueBytesStoreSupplier.cs | 2 +-
.../Kafka/Streams/State/KeyValueIterator.cs | 10 +-
.../Kafka/Streams/State/KeyValueStore.cs | 10 +-
.../Kafka/Streams/State/QueryableStoreType.cs | 6 +-
.../Streams/State/QueryableStoreTypes.cs | 2 +-
.../Streams/State/ReadOnlyKeyValueStore.cs | 18 +-
.../Streams/State/ReadOnlySessionStore.cs | 10 +-
.../Streams/State/ReadOnlyWindowStore.cs | 10 +-
.../Streams/State/RocksDBConfigSetter.cs | 2 +-
.../State/SessionBytesStoreSupplier.cs | 6 +-
.../Kafka/Streams/State/SessionStore.cs | 6 +-
.../Apache/Kafka/Streams/State/StateSerdes.cs | 46 ++---
.../Kafka/Streams/State/StoreBuilder.cs | 34 ++--
.../Kafka/Streams/State/StoreSupplier.cs | 14 +-
.../Org/Apache/Kafka/Streams/State/Stores.cs | 8 +-
.../Streams/State/TimestampedBytesStore.cs | 4 +-
.../Streams/State/TimestampedKeyValueStore.cs | 2 +-
.../Streams/State/TimestampedWindowStore.cs | 2 +-
.../Kafka/Streams/State/ValueAndTimestamp.cs | 14 +-
.../Streams/State/VersionedBytesStore.cs | 2 +-
.../State/VersionedBytesStoreSupplier.cs | 4 +-
.../Streams/State/VersionedKeyValueStore.cs | 6 +-
.../Kafka/Streams/State/VersionedRecord.cs | 10 +-
.../Streams/State/WindowBytesStoreSupplier.cs | 10 +-
.../Apache/Kafka/Streams/State/WindowStore.cs | 2 +-
.../Streams/State/WindowStoreIterator.cs | 6 +-
.../Kafka/Streams/StoreQueryParameters.cs | 26 +--
.../Apache/Kafka/Streams/StreamsBuilder.cs | 8 +-
.../Org/Apache/Kafka/Streams/StreamsConfig.cs | 46 ++---
.../Apache/Kafka/Streams/StreamsMetadata.cs | 16 +-
.../Apache/Kafka/Streams/StreamsMetrics.cs | 6 +-
.../Org/Apache/Kafka/Streams/TaskMetadata.cs | 12 +-
.../Apache/Kafka/Streams/ThreadMetadata.cs | 18 +-
.../Org/Apache/Kafka/Streams/Topology.cs | 8 +-
.../Apache/Kafka/Streams/TopologyConfig.cs | 8 +-
.../Kafka/Streams/TopologyDescription.cs | 32 +--
.../Apache/Kafka/Tools/AllPackageClasses.cs | 2 +-
.../Kafka/Tools/ClientCompatibilityTest.cs | 8 +-
.../Org/Apache/Kafka/Tools/ClusterTool.cs | 4 +-
.../Apache/Kafka/Tools/ConnectPluginPath.cs | 4 +-
.../Apache/Kafka/Tools/ConsumerPerformance.cs | 4 +-
.../Kafka/Tools/DelegationTokenCommand.cs | 4 +-
.../Kafka/Tools/DeleteRecordsCommand.cs | 4 +-
.../Org/Apache/Kafka/Tools/EndToEndLatency.cs | 4 +-
.../Org/Apache/Kafka/Tools/FeatureCommand.cs | 4 +-
.../Org/Apache/Kafka/Tools/JmxTool.cs | 4 +-
.../Org/Apache/Kafka/Tools/LogDirsCommand.cs | 4 +-
.../Apache/Kafka/Tools/ManifestWorkspace.cs | 8 +-
.../Kafka/Tools/MetadataQuorumCommand.cs | 4 +-
.../Kafka/Tools/OAuthCompatibilityTool.cs | 4 +-
.../Apache/Kafka/Tools/ProducerPerformance.cs | 4 +-
.../Kafka/Tools/PushHttpMetricsReporter.cs | 12 +-
.../Kafka/Tools/Reassign/AllPackageClasses.cs | 2 +-
.../ReassignPartitionsCommandOptions.cs | 2 +-
.../Tools/Reassign/VerifyAssignmentResult.cs | 2 +-
.../Kafka/Tools/ReplicaVerificationTool.cs | 4 +-
.../Org/Apache/Kafka/Tools/StreamsResetter.cs | 8 +-
.../Org/Apache/Kafka/Tools/TerseException.cs | 2 +-
.../Org/Apache/Kafka/Tools/ToolsUtils.cs | 4 +-
.../Kafka/Tools/TransactionalMessageCopier.cs | 4 +-
.../Apache/Kafka/Tools/TransactionsCommand.cs | 4 +-
.../Apache/Kafka/Tools/VerifiableConsumer.cs | 14 +-
.../Kafka/Tools/VerifiableLog4jAppender.cs | 8 +-
.../Apache/Kafka/Tools/VerifiableProducer.cs | 12 +-
.../Org/Apache/Zookeeper/AllPackageClasses.cs | 2 +-
1058 files changed, 4920 insertions(+), 4920 deletions(-)
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/ConsumerInterceptor.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/ConsumerInterceptor.java
index f05287364b..9ce70d0ab4 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/ConsumerInterceptor.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/ConsumerInterceptor.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.clients.consumer;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/ConsumerPartitionAssignor.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/ConsumerPartitionAssignor.java
index 734f1114da..6e69b2fd01 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/ConsumerPartitionAssignor.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/ConsumerPartitionAssignor.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.clients.consumer;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/ConsumerRebalanceListener.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/ConsumerRebalanceListener.java
index a47c548102..e4f3a9ec24 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/ConsumerRebalanceListener.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/ConsumerRebalanceListener.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.clients.consumer;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/OffsetCommitCallback.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/OffsetCommitCallback.java
index 366442cd12..11f7787bf5 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/OffsetCommitCallback.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/OffsetCommitCallback.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.clients.consumer;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/producer/Callback.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/producer/Callback.java
index 84040c7f32..94f4ab87c4 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/producer/Callback.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/producer/Callback.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.clients.producer;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/producer/Partitioner.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/producer/Partitioner.java
index 97f70cbe8b..4aa6d32f3d 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/producer/Partitioner.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/producer/Partitioner.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.clients.producer;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/producer/ProducerInterceptor.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/producer/ProducerInterceptor.java
index e3b6318d4c..53c68bf0f5 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/producer/ProducerInterceptor.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/producer/ProducerInterceptor.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.clients.producer;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/ClusterResourceListener.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/ClusterResourceListener.java
index c0c85bcd84..2189abe0bf 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/ClusterResourceListener.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/ClusterResourceListener.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.common;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/config/ConfigChangeCallback.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/config/ConfigChangeCallback.java
index 25537ef7b7..d79e9cea2c 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/config/ConfigChangeCallback.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/config/ConfigChangeCallback.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.common.config;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/metrics/MetricsReporter.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/metrics/MetricsReporter.java
index 684a3f0ad4..7490428379 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/metrics/MetricsReporter.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/metrics/MetricsReporter.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.common.metrics;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/serialization/Deserializer.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/serialization/Deserializer.java
index f1364c8a12..dd8fb1bcc7 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/serialization/Deserializer.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/serialization/Deserializer.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.common.serialization;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/serialization/Serde.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/serialization/Serde.java
index 281a4238fa..711facde11 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/serialization/Serde.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/serialization/Serde.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.common.serialization;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/serialization/Serializer.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/serialization/Serializer.java
index f819207617..fc2124a1af 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/serialization/Serializer.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/serialization/Serializer.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.common.serialization;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/raft/Listener.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/raft/Listener.java
index a27c5fa6f4..0da81208eb 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/raft/Listener.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/raft/Listener.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.raft;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/KafkaClientSupplier.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/KafkaClientSupplier.java
index e01244254e..31f73e5f0b 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/KafkaClientSupplier.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/KafkaClientSupplier.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/StateListener.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/StateListener.java
index 09a07e4ab1..033251db50 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/StateListener.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/StateListener.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/errors/StreamsUncaughtExceptionHandler.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/errors/StreamsUncaughtExceptionHandler.java
index 23cdce0301..67aabe2c0f 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/errors/StreamsUncaughtExceptionHandler.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/errors/StreamsUncaughtExceptionHandler.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.errors;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Aggregator.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Aggregator.java
index 535d062939..ba5e6de805 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Aggregator.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Aggregator.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.kstream;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ForeachAction.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ForeachAction.java
index e07914d3d5..880d93165c 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ForeachAction.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ForeachAction.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.kstream;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Initializer.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Initializer.java
index 7b41b9b5e2..da9552afc4 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Initializer.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Initializer.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.kstream;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/KeyValueMapper.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/KeyValueMapper.java
index c5fbcb24ee..730f9e88f1 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/KeyValueMapper.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/KeyValueMapper.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.kstream;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Merger.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Merger.java
index d22487d823..5e72841915 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Merger.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Merger.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.kstream;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Predicate.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Predicate.java
index 96d8cca34e..3eaf913949 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Predicate.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Predicate.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.kstream;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Reducer.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Reducer.java
index cae214eafe..38eccf08a5 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Reducer.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Reducer.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.kstream;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Transformer.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Transformer.java
index 062dede564..6db7f8ddf0 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Transformer.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Transformer.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.kstream;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueJoiner.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueJoiner.java
index dd7a1261a7..e89238ec9e 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueJoiner.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueJoiner.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.kstream;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueJoinerWithKey.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueJoinerWithKey.java
index 505319742a..cd8dfef57a 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueJoinerWithKey.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueJoinerWithKey.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.kstream;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueMapper.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueMapper.java
index 0537101f35..9413833437 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueMapper.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueMapper.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.kstream;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueMapperWithKey.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueMapperWithKey.java
index 35f65f62da..a35c9a2ac6 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueMapperWithKey.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueMapperWithKey.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.kstream;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueTransformer.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueTransformer.java
index a7b20512c3..289ca07ae2 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueTransformer.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueTransformer.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.kstream;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueTransformerWithKey.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueTransformerWithKey.java
index 080bae7d47..cffbf06989 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueTransformerWithKey.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueTransformerWithKey.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.kstream;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/BatchingStateRestoreCallback.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/BatchingStateRestoreCallback.java
index 585b488d35..32cb7e4646 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/BatchingStateRestoreCallback.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/BatchingStateRestoreCallback.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.processor;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/Punctuator.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/Punctuator.java
index e16934a79b..9287c72d26 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/Punctuator.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/Punctuator.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.processor;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/StateRestoreCallback.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/StateRestoreCallback.java
index 8b0fdd77bc..ebce95e9b3 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/StateRestoreCallback.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/StateRestoreCallback.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.processor;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/StateRestoreListener.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/StateRestoreListener.java
index 6787731505..d3994a79c3 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/StateRestoreListener.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/StateRestoreListener.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.processor;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/StreamPartitioner.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/StreamPartitioner.java
index d99f60f78b..c6d622eba0 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/StreamPartitioner.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/StreamPartitioner.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.processor;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/TimestampExtractor.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/TimestampExtractor.java
index d44274a08b..6707a99b24 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/TimestampExtractor.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/TimestampExtractor.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.processor;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/TopicNameExtractor.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/TopicNameExtractor.java
index 89424e7e80..c3a601aed1 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/TopicNameExtractor.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/TopicNameExtractor.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.processor;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/api/FixedKeyProcessor.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/api/FixedKeyProcessor.java
index c0147e7aae..1bdcd978be 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/api/FixedKeyProcessor.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/api/FixedKeyProcessor.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.processor.api;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/api/Processor.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/api/Processor.java
index 4c3e86070e..c6cce56dfa 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/api/Processor.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/api/Processor.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.processor.api;
diff --git a/src/net/KNet/Generated/Kafka/Admin/AclCommand.cs b/src/net/KNet/Generated/Kafka/Admin/AclCommand.cs
index cffeefd8ac..68a056cca7 100644
--- a/src/net/KNet/Generated/Kafka/Admin/AclCommand.cs
+++ b/src/net/KNet/Generated/Kafka/Admin/AclCommand.cs
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
* using kafka_2.13-3.6.1.jar as reference
*/
@@ -48,7 +48,7 @@ public partial class AclCommand
///
public static bool IsDebugEnabled()
{
- return SExecute(LocalBridgeClazz, "isDebugEnabled");
+ return SExecuteWithSignature(LocalBridgeClazz, "isDebugEnabled", "()Z");
}
///
///
@@ -57,7 +57,7 @@ public static bool IsDebugEnabled()
///
public static bool IsTraceEnabled()
{
- return SExecute(LocalBridgeClazz, "isTraceEnabled");
+ return SExecuteWithSignature(LocalBridgeClazz, "isTraceEnabled", "()Z");
}
///
///
@@ -66,7 +66,7 @@ public static bool IsTraceEnabled()
///
public static Java.Lang.String AuthorizerDeprecationMessage()
{
- return SExecute(LocalBridgeClazz, "AuthorizerDeprecationMessage");
+ return SExecuteWithSignature(LocalBridgeClazz, "AuthorizerDeprecationMessage", "()Ljava/lang/String;");
}
///
///
@@ -75,7 +75,7 @@ public static Java.Lang.String AuthorizerDeprecationMessage()
///
public static Org.Apache.Kafka.Common.Resource.ResourcePatternFilter ClusterResourceFilter()
{
- return SExecute(LocalBridgeClazz, "ClusterResourceFilter");
+ return SExecuteWithSignature(LocalBridgeClazz, "ClusterResourceFilter", "()Lorg/apache/kafka/common/resource/ResourcePatternFilter;");
}
///
///
@@ -83,7 +83,7 @@ public static Org.Apache.Kafka.Common.Resource.ResourcePatternFilter ClusterReso
///
public static void Main(Java.Lang.String[] args)
{
- SExecute(LocalBridgeClazz, "main", new object[] { args });
+ SExecuteWithSignature(LocalBridgeClazz, "main", "([Ljava/lang/String;)V", new object[] { args });
}
#endregion
@@ -128,14 +128,14 @@ public AclCommandOptions(Java.Lang.String[] args)
///
public Java.Lang.String CommandConfigDoc()
{
- return IExecute("CommandConfigDoc");
+ return IExecuteWithSignature("CommandConfigDoc", "()Ljava/lang/String;");
}
///
///
///
public void CheckArgs()
{
- IExecute("checkArgs");
+ IExecuteWithSignature("checkArgs", "()V");
}
#endregion
@@ -173,21 +173,21 @@ public partial class AclCommandService
///
public void AddAcls()
{
- IExecute("addAcls");
+ IExecuteWithSignature("addAcls", "()V");
}
///
///
///
public void ListAcls()
{
- IExecute("listAcls");
+ IExecuteWithSignature("listAcls", "()V");
}
///
///
///
public void RemoveAcls()
{
- IExecute("removeAcls");
+ IExecuteWithSignature("removeAcls", "()V");
}
#endregion
@@ -235,7 +235,7 @@ public AdminClientService(Kafka.Admin.AclCommand.AclCommandOptions opts)
///
public bool IsDebugEnabled()
{
- return IExecute("isDebugEnabled");
+ return IExecuteWithSignature("isDebugEnabled", "()Z");
}
///
///
@@ -244,7 +244,7 @@ public bool IsDebugEnabled()
///
public bool IsTraceEnabled()
{
- return IExecute("isTraceEnabled");
+ return IExecuteWithSignature("isTraceEnabled", "()Z");
}
///
///
@@ -253,7 +253,7 @@ public bool IsTraceEnabled()
///
public Java.Lang.String LoggerName()
{
- return IExecute("loggerName");
+ return IExecuteWithSignature("loggerName", "()Ljava/lang/String;");
}
///
///
@@ -262,7 +262,7 @@ public Java.Lang.String LoggerName()
///
public Java.Lang.String LogIdent()
{
- return IExecute("logIdent");
+ return IExecuteWithSignature("logIdent", "()Ljava/lang/String;");
}
///
///
@@ -271,7 +271,7 @@ public Java.Lang.String LogIdent()
///
public Java.Lang.String MsgWithLogIdent(Java.Lang.String msg)
{
- return IExecute("msgWithLogIdent", msg);
+ return IExecuteWithSignature("msgWithLogIdent", "(Ljava/lang/String;)Ljava/lang/String;", msg);
}
///
///
@@ -280,28 +280,28 @@ public Java.Lang.String MsgWithLogIdent(Java.Lang.String msg)
///
public Kafka.Admin.AclCommand.AclCommandOptions Opts()
{
- return IExecute("opts");
+ return IExecuteWithSignature("opts", "()Lkafka/admin/AclCommand$AclCommandOptions;");
}
///
///
///
public void AddAcls()
{
- IExecute("addAcls");
+ IExecuteWithSignature("addAcls", "()V");
}
///
///
///
public void ListAcls()
{
- IExecute("listAcls");
+ IExecuteWithSignature("listAcls", "()V");
}
///
///
///
public void RemoveAcls()
{
- IExecute("removeAcls");
+ IExecuteWithSignature("removeAcls", "()V");
}
#endregion
@@ -350,7 +350,7 @@ public AuthorizerService(Java.Lang.String authorizerClassName, Kafka.Admin.AclCo
///
public bool IsDebugEnabled()
{
- return IExecute("isDebugEnabled");
+ return IExecuteWithSignature("isDebugEnabled", "()Z");
}
///
///
@@ -359,7 +359,7 @@ public bool IsDebugEnabled()
///
public bool IsTraceEnabled()
{
- return IExecute("isTraceEnabled");
+ return IExecuteWithSignature("isTraceEnabled", "()Z");
}
///
///
@@ -368,7 +368,7 @@ public bool IsTraceEnabled()
///
public Java.Lang.String AuthorizerClassName()
{
- return IExecute("authorizerClassName");
+ return IExecuteWithSignature("authorizerClassName", "()Ljava/lang/String;");
}
///
///
@@ -377,7 +377,7 @@ public Java.Lang.String AuthorizerClassName()
///
public Java.Lang.String LoggerName()
{
- return IExecute("loggerName");
+ return IExecuteWithSignature("loggerName", "()Ljava/lang/String;");
}
///
///
@@ -386,7 +386,7 @@ public Java.Lang.String LoggerName()
///
public Java.Lang.String LogIdent()
{
- return IExecute("logIdent");
+ return IExecuteWithSignature("logIdent", "()Ljava/lang/String;");
}
///
///
@@ -395,7 +395,7 @@ public Java.Lang.String LogIdent()
///
public Java.Lang.String MsgWithLogIdent(Java.Lang.String msg)
{
- return IExecute("msgWithLogIdent", msg);
+ return IExecuteWithSignature("msgWithLogIdent", "(Ljava/lang/String;)Ljava/lang/String;", msg);
}
///
///
@@ -404,28 +404,28 @@ public Java.Lang.String MsgWithLogIdent(Java.Lang.String msg)
///
public Kafka.Admin.AclCommand.AclCommandOptions Opts()
{
- return IExecute("opts");
+ return IExecuteWithSignature("opts", "()Lkafka/admin/AclCommand$AclCommandOptions;");
}
///
///
///
public void AddAcls()
{
- IExecute("addAcls");
+ IExecuteWithSignature("addAcls", "()V");
}
///
///
///
public void ListAcls()
{
- IExecute("listAcls");
+ IExecuteWithSignature("listAcls", "()V");
}
///
///
///
public void RemoveAcls()
{
- IExecute("removeAcls");
+ IExecuteWithSignature("removeAcls", "()V");
}
#endregion
diff --git a/src/net/KNet/Generated/Kafka/Admin/AllPackageClasses.cs b/src/net/KNet/Generated/Kafka/Admin/AllPackageClasses.cs
index 71a8c0d916..bf5594ca68 100644
--- a/src/net/KNet/Generated/Kafka/Admin/AllPackageClasses.cs
+++ b/src/net/KNet/Generated/Kafka/Admin/AllPackageClasses.cs
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
* using kafka_2.13-3.6.1.jar as reference
*/
diff --git a/src/net/KNet/Generated/Kafka/Admin/BrokerApiVersionsCommand.cs b/src/net/KNet/Generated/Kafka/Admin/BrokerApiVersionsCommand.cs
index 5c9d337d92..4bab7573ff 100644
--- a/src/net/KNet/Generated/Kafka/Admin/BrokerApiVersionsCommand.cs
+++ b/src/net/KNet/Generated/Kafka/Admin/BrokerApiVersionsCommand.cs
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
* using kafka_2.13-3.6.1.jar as reference
*/
@@ -56,7 +56,7 @@ public static void Execute(Java.Lang.String[] args, Java.Io.PrintStream _out)
///
public static void Main(Java.Lang.String[] args)
{
- SExecute(LocalBridgeClazz, "main", new object[] { args });
+ SExecuteWithSignature(LocalBridgeClazz, "main", "([Ljava/lang/String;)V", new object[] { args });
}
#endregion
@@ -101,7 +101,7 @@ public BrokerVersionCommandOptions(Java.Lang.String[] args)
///
public Java.Lang.String BootstrapServerDoc()
{
- return IExecute("BootstrapServerDoc");
+ return IExecuteWithSignature("BootstrapServerDoc", "()Ljava/lang/String;");
}
///
///
@@ -110,14 +110,14 @@ public Java.Lang.String BootstrapServerDoc()
///
public Java.Lang.String CommandConfigDoc()
{
- return IExecute("CommandConfigDoc");
+ return IExecuteWithSignature("CommandConfigDoc", "()Ljava/lang/String;");
}
///
///
///
public void CheckArgs()
{
- IExecute("checkArgs");
+ IExecuteWithSignature("checkArgs", "()V");
}
#endregion
diff --git a/src/net/KNet/Generated/Kafka/Admin/ConfigCommand.cs b/src/net/KNet/Generated/Kafka/Admin/ConfigCommand.cs
index 7714ef1641..0b9656c9d1 100644
--- a/src/net/KNet/Generated/Kafka/Admin/ConfigCommand.cs
+++ b/src/net/KNet/Generated/Kafka/Admin/ConfigCommand.cs
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
* using kafka_2.13-3.6.1.jar as reference
*/
@@ -48,7 +48,7 @@ public partial class ConfigCommand
///
public static bool IsDebugEnabled()
{
- return SExecute(LocalBridgeClazz, "isDebugEnabled");
+ return SExecuteWithSignature(LocalBridgeClazz, "isDebugEnabled", "()Z");
}
///
///
@@ -57,7 +57,7 @@ public static bool IsDebugEnabled()
///
public static bool IsTraceEnabled()
{
- return SExecute(LocalBridgeClazz, "isTraceEnabled");
+ return SExecuteWithSignature(LocalBridgeClazz, "isTraceEnabled", "()Z");
}
///
///
@@ -66,7 +66,7 @@ public static bool IsTraceEnabled()
///
public static int DefaultScramIterations()
{
- return SExecute(LocalBridgeClazz, "DefaultScramIterations");
+ return SExecuteWithSignature(LocalBridgeClazz, "DefaultScramIterations", "()I");
}
///
///
@@ -75,7 +75,7 @@ public static int DefaultScramIterations()
///
public static Java.Lang.String BrokerDefaultEntityName()
{
- return SExecute(LocalBridgeClazz, "BrokerDefaultEntityName");
+ return SExecuteWithSignature(LocalBridgeClazz, "BrokerDefaultEntityName", "()Ljava/lang/String;");
}
///
///
@@ -84,7 +84,7 @@ public static Java.Lang.String BrokerDefaultEntityName()
///
public static Java.Lang.String BrokerLoggerConfigType()
{
- return SExecute(LocalBridgeClazz, "BrokerLoggerConfigType");
+ return SExecuteWithSignature(LocalBridgeClazz, "BrokerLoggerConfigType", "()Ljava/lang/String;");
}
///
///
@@ -92,7 +92,7 @@ public static Java.Lang.String BrokerLoggerConfigType()
///
public static void Main(Java.Lang.String[] args)
{
- SExecute(LocalBridgeClazz, "main", new object[] { args });
+ SExecuteWithSignature(LocalBridgeClazz, "main", "([Ljava/lang/String;)V", new object[] { args });
}
#endregion
@@ -137,14 +137,14 @@ public ConfigCommandOptions(Java.Lang.String[] args)
///
public Java.Lang.String Nl()
{
- return IExecute("nl");
+ return IExecuteWithSignature("nl", "()Ljava/lang/String;");
}
///
///
///
public void CheckArgs()
{
- IExecute("checkArgs");
+ IExecuteWithSignature("checkArgs", "()V");
}
#endregion
@@ -188,7 +188,7 @@ public partial class ConfigEntity : Java.Io.ISerializable
///
public bool CanEqual(object x_1)
{
- return IExecute("canEqual", x_1);
+ return IExecuteWithSignature("canEqual", "(Ljava/lang/Object;)Z", x_1);
}
///
///
@@ -197,7 +197,7 @@ public bool CanEqual(object x_1)
///
public int ProductArity()
{
- return IExecute("productArity");
+ return IExecuteWithSignature("productArity", "()I");
}
///
///
@@ -206,7 +206,7 @@ public int ProductArity()
///
public object ProductElement(int x_1)
{
- return IExecute("productElement", x_1);
+ return IExecuteWithSignature("productElement", "(I)Ljava/lang/Object;", x_1);
}
///
///
@@ -215,7 +215,7 @@ public object ProductElement(int x_1)
///
public Java.Lang.String FullSanitizedName()
{
- return IExecute("fullSanitizedName");
+ return IExecuteWithSignature("fullSanitizedName", "()Ljava/lang/String;");
}
///
///
@@ -224,7 +224,7 @@ public Java.Lang.String FullSanitizedName()
///
public Java.Lang.String ProductElementName(int x_1)
{
- return IExecute("productElementName", x_1);
+ return IExecuteWithSignature("productElementName", "(I)Ljava/lang/String;", x_1);
}
///
///
@@ -233,7 +233,7 @@ public Java.Lang.String ProductElementName(int x_1)
///
public Java.Lang.String ProductPrefix()
{
- return IExecute("productPrefix");
+ return IExecuteWithSignature("productPrefix", "()Ljava/lang/String;");
}
///
///
@@ -242,7 +242,7 @@ public Java.Lang.String ProductPrefix()
///
public Kafka.Admin.ConfigCommand.Entity Root()
{
- return IExecute("root");
+ return IExecuteWithSignature("root", "()Lkafka/admin/ConfigCommand$Entity;");
}
#endregion
@@ -286,7 +286,7 @@ public partial class Entity : Java.Io.ISerializable
///
public bool CanEqual(object x_1)
{
- return IExecute("canEqual", x_1);
+ return IExecuteWithSignature("canEqual", "(Ljava/lang/Object;)Z", x_1);
}
///
///
@@ -295,7 +295,7 @@ public bool CanEqual(object x_1)
///
public int ProductArity()
{
- return IExecute("productArity");
+ return IExecuteWithSignature("productArity", "()I");
}
///
///
@@ -304,7 +304,7 @@ public int ProductArity()
///
public object ProductElement(int x_1)
{
- return IExecute("productElement", x_1);
+ return IExecuteWithSignature("productElement", "(I)Ljava/lang/Object;", x_1);
}
///
///
@@ -313,7 +313,7 @@ public object ProductElement(int x_1)
///
public Java.Lang.String EntityPath()
{
- return IExecute("entityPath");
+ return IExecuteWithSignature("entityPath", "()Ljava/lang/String;");
}
///
///
@@ -322,7 +322,7 @@ public Java.Lang.String EntityPath()
///
public Java.Lang.String EntityType()
{
- return IExecute("entityType");
+ return IExecuteWithSignature("entityType", "()Ljava/lang/String;");
}
///
///
@@ -331,7 +331,7 @@ public Java.Lang.String EntityType()
///
public Java.Lang.String ProductElementName(int x_1)
{
- return IExecute("productElementName", x_1);
+ return IExecuteWithSignature("productElementName", "(I)Ljava/lang/String;", x_1);
}
///
///
@@ -340,7 +340,7 @@ public Java.Lang.String ProductElementName(int x_1)
///
public Java.Lang.String ProductPrefix()
{
- return IExecute("productPrefix");
+ return IExecuteWithSignature("productPrefix", "()Ljava/lang/String;");
}
#endregion
diff --git a/src/net/KNet/Generated/Kafka/Admin/ConsumerGroupCommand.cs b/src/net/KNet/Generated/Kafka/Admin/ConsumerGroupCommand.cs
index b4ee7d7566..af8c1d470b 100644
--- a/src/net/KNet/Generated/Kafka/Admin/ConsumerGroupCommand.cs
+++ b/src/net/KNet/Generated/Kafka/Admin/ConsumerGroupCommand.cs
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.3.0.0)
+* This file is generated by MASES.JNetReflector (ver. 2.4.0.0)
* using kafka_2.13-3.6.1.jar as reference
*/
@@ -48,7 +48,7 @@ public partial class ConsumerGroupCommand
///
public static bool IsDebugEnabled()
{
- return SExecute(LocalBridgeClazz, "isDebugEnabled");
+ return SExecuteWithSignature(LocalBridgeClazz, "isDebugEnabled", "()Z");
}
///
///
@@ -57,7 +57,7 @@ public static bool IsDebugEnabled()
///
public static bool IsTraceEnabled()
{
- return SExecute(LocalBridgeClazz, "isTraceEnabled");
+ return SExecuteWithSignature(LocalBridgeClazz, "isTraceEnabled", "()Z");
}
///
///
@@ -66,7 +66,7 @@ public static bool IsTraceEnabled()
///
public static Java.Lang.String MISSING_COLUMN_VALUE()
{
- return SExecute(LocalBridgeClazz, "MISSING_COLUMN_VALUE");
+ return SExecuteWithSignature(LocalBridgeClazz, "MISSING_COLUMN_VALUE", "()Ljava/lang/String;");
}
///
///
@@ -74,7 +74,7 @@ public static Java.Lang.String MISSING_COLUMN_VALUE()
///
public static void Main(Java.Lang.String[] args)
{
- SExecute(LocalBridgeClazz, "main", new object[] { args });
+ SExecuteWithSignature(LocalBridgeClazz, "main", "([Ljava/lang/String;)V", new object[] { args });
}
///
///
@@ -82,7 +82,7 @@ public static void Main(Java.Lang.String[] args)
///
public static void Run(Kafka.Admin.ConsumerGroupCommand.ConsumerGroupCommandOptions opts)
{
- SExecute(LocalBridgeClazz, "run", opts);
+ SExecuteWithSignature(LocalBridgeClazz, "run", "(Lkafka/admin/ConsumerGroupCommand$ConsumerGroupCommandOptions;)V", opts);
}
#endregion
@@ -127,7 +127,7 @@ public ConsumerGroupCommandOptions(Java.Lang.String[] args)
///
public Java.Lang.String AllGroupsDoc()
{
- return IExecute("AllGroupsDoc");
+ return IExecuteWithSignature("AllGroupsDoc", "()Ljava/lang/String;");
}
///
///
@@ -136,7 +136,7 @@ public Java.Lang.String AllGroupsDoc()
///
public Java.Lang.String AllTopicsDoc()
{
- return IExecute("AllTopicsDoc");
+ return IExecuteWithSignature("AllTopicsDoc", "()Ljava/lang/String;");
}
///
///
@@ -145,7 +145,7 @@ public Java.Lang.String AllTopicsDoc()
///
public Java.Lang.String BootstrapServerDoc()
{
- return IExecute("BootstrapServerDoc");
+ return IExecuteWithSignature("BootstrapServerDoc", "()Ljava/lang/String;");
}
///
///
@@ -154,7 +154,7 @@ public Java.Lang.String BootstrapServerDoc()
///
public Java.Lang.String CommandConfigDoc()
{
- return IExecute("CommandConfigDoc");
+ return IExecuteWithSignature("CommandConfigDoc", "()Ljava/lang/String;");
}
///
///
@@ -163,7 +163,7 @@ public Java.Lang.String CommandConfigDoc()
///
public Java.Lang.String DeleteDoc()
{
- return IExecute("DeleteDoc");
+ return IExecuteWithSignature("DeleteDoc", "()Ljava/lang/String;");
}
///
///
@@ -172,7 +172,7 @@ public Java.Lang.String DeleteDoc()
///
public Java.Lang.String DeleteOffsetsDoc()
{
- return IExecute("DeleteOffsetsDoc");
+ return IExecuteWithSignature("DeleteOffsetsDoc", "()Ljava/lang/String;");
}
///
///
@@ -181,7 +181,7 @@ public Java.Lang.String DeleteOffsetsDoc()
///
public Java.Lang.String DescribeDoc()
{
- return IExecute("DescribeDoc");
+ return IExecuteWithSignature("DescribeDoc", "()Ljava/lang/String;");
}
///
///
@@ -190,7 +190,7 @@ public Java.Lang.String DescribeDoc()
///
public Java.Lang.String DryRunDoc()
{
- return IExecute("DryRunDoc");
+ return IExecuteWithSignature("DryRunDoc", "()Ljava/lang/String;");
}
///
///
@@ -199,7 +199,7 @@ public Java.Lang.String DryRunDoc()
///
public Java.Lang.String ExecuteDoc()
{
- return IExecute("ExecuteDoc");
+ return IExecuteWithSignature("ExecuteDoc", "()Ljava/lang/String;");
}
///
///
@@ -208,7 +208,7 @@ public Java.Lang.String ExecuteDoc()
///
public Java.Lang.String ExportDoc()
{
- return IExecute("ExportDoc");
+ return IExecuteWithSignature("ExportDoc", "()Ljava/lang/String;");
}
///
///
@@ -217,7 +217,7 @@ public Java.Lang.String ExportDoc()
///
public Java.Lang.String GroupDoc()
{
- return IExecute("GroupDoc");
+ return IExecuteWithSignature("GroupDoc", "()Ljava/lang/String;");
}
///
///
@@ -226,7 +226,7 @@ public Java.Lang.String GroupDoc()
///
public Java.Lang.String ListDoc()
{
- return IExecute("ListDoc");
+ return IExecuteWithSignature("ListDoc", "()Ljava/lang/String;");
}
///
///
@@ -235,7 +235,7 @@ public Java.Lang.String ListDoc()
///
public Java.Lang.String MembersDoc()
{
- return IExecute("MembersDoc");
+ return IExecuteWithSignature("MembersDoc", "()Ljava/lang/String;");
}
///
///
@@ -244,7 +244,7 @@ public Java.Lang.String MembersDoc()
///
public Java.Lang.String Nl()
{
- return IExecute("nl");
+ return IExecuteWithSignature("nl", "()Ljava/lang/String;");
}
///
///
@@ -253,7 +253,7 @@ public Java.Lang.String Nl()
///
public Java.Lang.String OffsetsDoc()
{
- return IExecute("OffsetsDoc");
+ return IExecuteWithSignature("OffsetsDoc", "()Ljava/lang/String;");
}
///
///
@@ -262,7 +262,7 @@ public Java.Lang.String OffsetsDoc()
///
public Java.Lang.String ResetByDurationDoc()
{
- return IExecute("ResetByDurationDoc");
+ return IExecuteWithSignature("ResetByDurationDoc", "()Ljava/lang/String;");
}
///
///
@@ -271,7 +271,7 @@ public Java.Lang.String ResetByDurationDoc()
///
public Java.Lang.String ResetFromFileDoc()
{
- return IExecute("ResetFromFileDoc");
+ return IExecuteWithSignature("ResetFromFileDoc", "()Ljava/lang/String;");
}
///
///
@@ -280,7 +280,7 @@ public Java.Lang.String ResetFromFileDoc()
///
public Java.Lang.String ResetOffsetsDoc()
{
- return IExecute("ResetOffsetsDoc");
+ return IExecuteWithSignature("ResetOffsetsDoc", "()Ljava/lang/String;");
}
///
///
@@ -289,7 +289,7 @@ public Java.Lang.String ResetOffsetsDoc()
///
public Java.Lang.String ResetShiftByDoc()
{
- return IExecute("ResetShiftByDoc");
+ return IExecuteWithSignature("ResetShiftByDoc", "()Ljava/lang/String;");
}
///
///
@@ -298,7 +298,7 @@ public Java.Lang.String ResetShiftByDoc()
///
public Java.Lang.String ResetToCurrentDoc()
{
- return IExecute("ResetToCurrentDoc");
+ return IExecuteWithSignature("ResetToCurrentDoc", "()Ljava/lang/String;");
}
///
///
@@ -307,7 +307,7 @@ public Java.Lang.String ResetToCurrentDoc()
///
public Java.Lang.String ResetToDatetimeDoc()
{
- return IExecute("ResetToDatetimeDoc");
+ return IExecuteWithSignature("ResetToDatetimeDoc", "()Ljava/lang/String;");
}
///
///
@@ -316,7 +316,7 @@ public Java.Lang.String ResetToDatetimeDoc()
///
public Java.Lang.String ResetToEarliestDoc()
{
- return IExecute("ResetToEarliestDoc");
+ return IExecuteWithSignature("ResetToEarliestDoc", "()Ljava/lang/String;");
}
///
///
@@ -325,7 +325,7 @@ public Java.Lang.String ResetToEarliestDoc()
///
public Java.Lang.String ResetToLatestDoc()
{
- return IExecute("ResetToLatestDoc");
+ return IExecuteWithSignature("ResetToLatestDoc", "()Ljava/lang/String;");
}
///
///
@@ -334,7 +334,7 @@ public Java.Lang.String ResetToLatestDoc()
///
public Java.Lang.String ResetToOffsetDoc()
{
- return IExecute("ResetToOffsetDoc");
+ return IExecuteWithSignature("ResetToOffsetDoc", "()Ljava/lang/String;");
}
///
///
@@ -343,7 +343,7 @@ public Java.Lang.String ResetToOffsetDoc()
///
public Java.Lang.String StateDoc()
{
- return IExecute("StateDoc");
+ return IExecuteWithSignature("StateDoc", "()Ljava/lang/String;");
}
///
///
@@ -352,7 +352,7 @@ public Java.Lang.String StateDoc()
///
public Java.Lang.String TimeoutMsDoc()
{
- return IExecute("TimeoutMsDoc");
+ return IExecuteWithSignature("TimeoutMsDoc", "()Ljava/lang/String;");
}
///
///
@@ -361,7 +361,7 @@ public Java.Lang.String TimeoutMsDoc()
///
public Java.Lang.String TopicDoc()
{
- return IExecute("TopicDoc");
+ return IExecuteWithSignature("TopicDoc", "()Ljava/lang/String;");
}
///
///
@@ -370,14 +370,14 @@ public Java.Lang.String TopicDoc()
///
public Java.Lang.String VerboseDoc()
{
- return IExecute("VerboseDoc");
+ return IExecuteWithSignature("VerboseDoc", "()Ljava/lang/String;");
}
///
///
///
public void CheckArgs()
{
- IExecute("checkArgs");
+ IExecuteWithSignature("checkArgs", "()V");
}
#endregion
@@ -417,7 +417,7 @@ public partial class ConsumerGroupService
///
public Kafka.Admin.ConsumerGroupCommand.ConsumerGroupCommandOptions Opts()
{
- return IExecute("opts");
+ return IExecuteWithSignature("opts", "()Lkafka/admin/ConsumerGroupCommand$ConsumerGroupCommandOptions;");
}
///
///
@@ -426,35 +426,35 @@ public Kafka.Admin.ConsumerGroupCommand.ConsumerGroupCommandOptions Opts()
///
public Kafka.Admin.ConsumerGroupCommand.GroupState CollectGroupState(Java.Lang.String groupId)
{
- return IExecute("collectGroupState", groupId);
+ return IExecuteWithSignature("collectGroupState", "(Ljava/lang/String;)Lkafka/admin/ConsumerGroupCommand$GroupState;", groupId);
}
///
///
///
public void Close()
{
- IExecute("close");
+ IExecuteWithSignature("close", "()V");
}
///
///
///
public void DeleteOffsets()
{
- IExecute("deleteOffsets");
+ IExecuteWithSignature("deleteOffsets", "()V");
}
///
///
///
public void DescribeGroups()
{
- IExecute("describeGroups");
+ IExecuteWithSignature("describeGroups", "()V");
}
///
///
///
public void ListGroups()
{
- IExecute("listGroups");
+ IExecuteWithSignature("listGroups", "()V");
}
#endregion
@@ -539,7 +539,7 @@ public CsvRecordNoGroup(Java.Lang.String topic, int partition, long offset)
///
public bool CanEqual(object x_1)
{
- return IExecute("canEqual", x_1);
+ return IExecuteWithSignature("canEqual", "(Ljava/lang/Object;)Z", x_1);
}
///
///
@@ -548,7 +548,7 @@ public bool CanEqual(object x_1)
///
public int Partition()
{
- return IExecute("partition");
+ return IExecuteWithSignature("partition", "()I");
}
///
///
@@ -557,7 +557,7 @@ public int Partition()
///
public int ProductArity()
{
- return IExecute("productArity");
+ return IExecuteWithSignature("productArity", "()I");
}
///
///
@@ -566,7 +566,7 @@ public int ProductArity()
///
public object ProductElement(int x_1)
{
- return IExecute("productElement", x_1);
+ return IExecuteWithSignature("productElement", "(I)Ljava/lang/Object;", x_1);
}
///
///
@@ -575,7 +575,7 @@ public object ProductElement(int x_1)
///
public Java.Lang.String ProductElementName(int x_1)
{
- return IExecute("productElementName", x_1);
+ return IExecuteWithSignature("productElementName", "(I)Ljava/lang/String;", x_1);
}
///
///
@@ -584,7 +584,7 @@ public Java.Lang.String ProductElementName(int x_1)
///
public Java.Lang.String ProductPrefix()
{
- return IExecute("productPrefix");
+ return IExecuteWithSignature("productPrefix", "()Ljava/lang/String;");
}
///
///
@@ -593,7 +593,7 @@ public Java.Lang.String ProductPrefix()
///
public Java.Lang.String Topic()
{
- return IExecute("topic");
+ return IExecuteWithSignature("topic", "()Ljava/lang/String;");
}
///
///
@@ -613,7 +613,7 @@ public Kafka.Admin.ConsumerGroupCommand.CsvRecordNoGroup Copy(Java.Lang.String t
///
public long Offset()
{
- return IExecute("offset");
+ return IExecuteWithSignature("offset", "()J");
}
#endregion
@@ -668,7 +668,7 @@ public CsvRecordWithGroup(Java.Lang.String group, Java.Lang.String topic, int pa
///
public bool CanEqual(object x_1)
{
- return IExecute("canEqual", x_1);
+ return IExecuteWithSignature("canEqual", "(Ljava/lang/Object;)Z", x_1);
}
///
///
@@ -677,7 +677,7 @@ public bool CanEqual(object x_1)
///
public int Partition()
{
- return IExecute("partition");
+ return IExecuteWithSignature("partition", "()I");
}
///
///
@@ -686,7 +686,7 @@ public int Partition()
///
public int ProductArity()
{
- return IExecute("productArity");
+ return IExecuteWithSignature("productArity", "()I");
}
///
///
@@ -695,7 +695,7 @@ public int ProductArity()
///
public object ProductElement(int x_1)
{
- return IExecute("productElement", x_1);
+ return IExecuteWithSignature("productElement", "(I)Ljava/lang/Object;", x_1);
}
///
///
@@ -704,7 +704,7 @@ public object ProductElement(int x_1)
///
public Java.Lang.String Group()
{
- return IExecute("group");
+ return IExecuteWithSignature("group", "()Ljava/lang/String;");
}
///
///
@@ -713,7 +713,7 @@ public Java.Lang.String Group()
///
public Java.Lang.String ProductElementName(int x_1)
{
- return IExecute("productElementName", x_1);
+ return IExecuteWithSignature("productElementName", "(I)Ljava/lang/String;", x_1);
}
///
///
@@ -722,7 +722,7 @@ public Java.Lang.String ProductElementName(int x_1)
///
public Java.Lang.String ProductPrefix()
{
- return IExecute("productPrefix");
+ return IExecuteWithSignature("productPrefix", "()Ljava/lang/String;");
}
///
///
@@ -731,7 +731,7 @@ public Java.Lang.String ProductPrefix()
///
public Java.Lang.String Topic()
{
- return IExecute("topic");
+ return IExecuteWithSignature("topic", "()Ljava/lang/String;");
}
///
///
@@ -752,7 +752,7 @@ public Kafka.Admin.ConsumerGroupCommand.CsvRecordWithGroup Copy(Java.Lang.String
///
public long Offset()
{
- return IExecute("offset");
+ return IExecuteWithSignature("offset", "()J");
}
#endregion
@@ -796,7 +796,7 @@ public partial class CsvUtils : Java.Io.ISerializable
///
public bool CanEqual(object x_1)
{
- return IExecute("canEqual", x_1);
+ return IExecuteWithSignature("canEqual", "(Ljava/lang/Object;)Z", x_1);
}
///
///
@@ -805,7 +805,7 @@ public bool CanEqual(object x_1)
///