jar

io.streamthoughts : jikkou-provider-kafka

Maven & Gradle

Nov 28, 2023

Jikkou Extension :: Kafka · Integration between Apache Kafka and Jikkou

Table Of Contents

Latest Version

Download io.streamthoughts : jikkou-provider-kafka JAR file - Latest Versions:

All Versions

Download io.streamthoughts : jikkou-provider-kafka JAR file - All Versions:

Version Vulnerabilities Size Updated
0.32.x

View Java Class Source Code in JAR file

  1. Download JD-GUI to open JAR file and explore Java source code file (.class .java)
  2. Click menu "File → Open File..." or just drag-and-drop the JAR file in the JD-GUI window jikkou-provider-kafka-0.32.0.jar file.
    Once you open a JAR file, all the java classes in the JAR file will be displayed.

io.streamthoughts.jikkou.kafka.change.handlers.acls.builder

├─ io.streamthoughts.jikkou.kafka.change.handlers.acls.builder.AbstractKafkaAclBindingBuilder.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.change.handlers.acls.builder.LiteralKafkaAclBindingBuilder.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.change.handlers.acls.builder.TopicMatchingAclRulesBuilder.class - [JAR]

io.streamthoughts.jikkou.kafka.change.handlers.topics

├─ io.streamthoughts.jikkou.kafka.change.handlers.topics.CreateTopicChangeHandler.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.change.handlers.topics.DeleteTopicChangeHandler.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.change.handlers.topics.KafkaTopicChangeHandler.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.change.handlers.topics.TopicChangeDescription.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.change.handlers.topics.UpdateTopicChangeHandler.class - [JAR]

io.streamthoughts.jikkou.kafka.models

├─ io.streamthoughts.jikkou.kafka.models.V1KafkaAclChange.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.models.V1KafkaAclChangeList.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.models.V1KafkaBroker.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.models.V1KafkaBrokersSpec.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.models.V1KafkaClientQuota.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.models.V1KafkaClientQuotaChange.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.models.V1KafkaClientQuotaChangeList.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.models.V1KafkaClientQuotaEntity.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.models.V1KafkaClientQuotaSpec.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.models.V1KafkaConsumerGroup.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.models.V1KafkaConsumerGroupMember.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.models.V1KafkaConsumerGroupStatus.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.models.V1KafkaConsumerOffset.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.models.V1KafkaNode.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.models.V1KafkaPrincipalAcl.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.models.V1KafkaPrincipalAuthorization.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.models.V1KafkaPrincipalAuthorizationSpec.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.models.V1KafkaPrincipalRole.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.models.V1KafkaPrincipalRoleSpec.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.models.V1KafkaResourceMatcher.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.models.V1KafkaTableRecord.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.models.V1KafkaTableRecordSpec.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.models.V1KafkaTopic.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.models.V1KafkaTopicChange.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.models.V1KafkaTopicChangeList.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.models.V1KafkaTopicSpec.class - [JAR]

io.streamthoughts.jikkou.kafka

├─ io.streamthoughts.jikkou.kafka.KafkaExtensionProvider.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.KafkaLabelAndAnnotations.class - [JAR]

io.streamthoughts.jikkou.kafka.collections

├─ io.streamthoughts.jikkou.kafka.collections.V1KafkaBrokerList.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.collections.V1KafkaClientQuotaList.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.collections.V1KafkaConsumerGroupList.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.collections.V1KafkaTableRecordList.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.collections.V1KafkaTopicList.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.collections.V1V1KafkaPrincipalAuthorizationList.class - [JAR]

io.streamthoughts.jikkou.kafka.internals.consumer

├─ io.streamthoughts.jikkou.kafka.internals.consumer.ConsumerFactory.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.internals.consumer.ConsumerRecordCallback.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.internals.consumer.DefaultConsumerFactory.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.internals.consumer.KafkaLogToEndConsumer.class - [JAR]

io.streamthoughts.jikkou.kafka.adapters

├─ io.streamthoughts.jikkou.kafka.adapters.KafkaAclBindingAdapter.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.adapters.KafkaConfigsAdapter.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.adapters.V1KafkaClientQuotaConfigsAdapter.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.adapters.V1KafkaPrincipalAuthorizationSupport.class - [JAR]

io.streamthoughts.jikkou.kafka.change.handlers.acls

├─ io.streamthoughts.jikkou.kafka.change.handlers.acls.AclChangeDescription.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.change.handlers.acls.CreateAclChangeHandler.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.change.handlers.acls.DeleteAclChangeHandler.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.change.handlers.acls.KafkaAclBindingBuilder.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.change.handlers.acls.KafkaAclChangeHandler.class - [JAR]

io.streamthoughts.jikkou.kafka.change

├─ io.streamthoughts.jikkou.kafka.change.AclChange.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.change.AclChangeComputer.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.change.ConsumerGroupChangeComputer.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.change.KafkaTableRecordChange.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.change.KafkaTableRecordChangeComputer.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.change.QuotaChange.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.change.QuotaChangeComputer.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.change.TopicChange.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.change.TopicChangeComputer.class - [JAR]

io.streamthoughts.jikkou.kafka.model

├─ io.streamthoughts.jikkou.kafka.model.DataHandle.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.model.DataType.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.model.DataValue.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.model.KafkaAclBinding.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.model.KafkaAclResource.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.model.KafkaClientQuotaConfigs.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.model.KafkaClientQuotaType.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.model.KafkaRecordHeader.class - [JAR]

io.streamthoughts.jikkou.kafka.reconcilier

├─ io.streamthoughts.jikkou.kafka.reconcilier.AdminClientConsumerGroupCollector.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.reconcilier.AdminClientConsumerGroupController.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.reconcilier.AdminClientKafkaAclCollector.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.reconcilier.AdminClientKafkaAclController.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.reconcilier.AdminClientKafkaBrokerCollector.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.reconcilier.AdminClientKafkaConfigs.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.reconcilier.AdminClientKafkaQuotaCollector.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.reconcilier.AdminClientKafkaQuotaController.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.reconcilier.AdminClientKafkaTableCollector.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.reconcilier.AdminClientKafkaTableController.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.reconcilier.AdminClientKafkaTopicCollector.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.reconcilier.AdminClientKafkaTopicController.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.reconcilier.KafkaClientConfiguration.class - [JAR]

io.streamthoughts.jikkou.kafka.transform

├─ io.streamthoughts.jikkou.kafka.transform.KafkaPrincipalAuthorizationTransformation.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.transform.KafkaTopicMaxNumPartitionsTransformation.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.transform.KafkaTopicMaxReplicasTransformation.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.transform.KafkaTopicMaxRetentionMsTransformation.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.transform.KafkaTopicMinInSyncReplicasTransformation.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.transform.KafkaTopicMinReplicasTransformation.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.transform.KafkaTopicMinRetentionMsTransformation.class - [JAR]

io.streamthoughts.jikkou.kafka.reconcilier.service

├─ io.streamthoughts.jikkou.kafka.reconcilier.service.KafkaConsumerGroupService.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.reconcilier.service.KafkaOffsetSpec.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.reconcilier.service.KafkaTopicService.class - [JAR]

io.streamthoughts.jikkou.kafka.reporter

├─ io.streamthoughts.jikkou.kafka.reporter.KafkaChangeReporter.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.reporter.KafkaChangeReporterConfig.class - [JAR]

io.streamthoughts.jikkou.kafka.internals.admin

├─ io.streamthoughts.jikkou.kafka.internals.admin.AdminClientContext.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.internals.admin.AdminClientContextFactory.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.internals.admin.AdminClientFactory.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.internals.admin.DefaultAdminClientFactory.class - [JAR]

io.streamthoughts.jikkou.kafka.internals

├─ io.streamthoughts.jikkou.kafka.internals.ConfigsBuilder.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.internals.DataSerde.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.internals.Futures.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.internals.KafkaBrokersReady.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.internals.KafkaConfigPredicate.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.internals.KafkaRecord.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.internals.KafkaTopics.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.internals.KafkaUtils.class - [JAR]

io.streamthoughts.jikkou.kafka.change.handlers.record

├─ io.streamthoughts.jikkou.kafka.change.handlers.record.KafkaTableRecordChangeDescription.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.change.handlers.record.KafkaTableRecordChangeHandler.class - [JAR]

io.streamthoughts.jikkou.kafka.internals.producer

├─ io.streamthoughts.jikkou.kafka.internals.producer.DefaultProducerFactory.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.internals.producer.KafkaRecordSender.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.internals.producer.ProducerFactory.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.internals.producer.ProducerRequestResult.class - [JAR]

io.streamthoughts.jikkou.kafka.health

├─ io.streamthoughts.jikkou.kafka.health.KafkaBrokerHealthIndicator.class - [JAR]

io.streamthoughts.jikkou.kafka.change.handlers.quotas

├─ io.streamthoughts.jikkou.kafka.change.handlers.quotas.AbstractQuotaChangeHandler.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.change.handlers.quotas.CreateQuotasChangeHandlerKafka.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.change.handlers.quotas.DeleteQuotasChangeHandler.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.change.handlers.quotas.KafkaQuotaChangeHandler.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.change.handlers.quotas.QuotaChangeDescription.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.change.handlers.quotas.UpdateQuotasChangeHandlerKafka.class - [JAR]

io.streamthoughts.jikkou.kafka.validation

├─ io.streamthoughts.jikkou.kafka.validation.ClientQuotaValidation.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.validation.NoDuplicatePrincipalAllowedValidation.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.validation.NoDuplicatePrincipalRoleValidation.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.validation.NoDuplicateTopicsAllowedValidation.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.validation.TopicConfigKeysValidation.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.validation.TopicMaxNumPartitionsValidation.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.validation.TopicMaxReplicationFactorValidation.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.validation.TopicMinNumPartitionsValidation.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.validation.TopicMinReplicationFactorValidation.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.validation.TopicNamePrefixValidation.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.validation.TopicNameRegexValidation.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.validation.TopicNameSuffixValidation.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.validation.TopicValidation.class - [JAR]

io.streamthoughts.jikkou.kafka.internals.serdes

├─ io.streamthoughts.jikkou.kafka.internals.serdes.KafkaJsonSerdes.class - [JAR]

io.streamthoughts.jikkou.kafka.change.handlers.consumer

├─ io.streamthoughts.jikkou.kafka.change.handlers.consumer.ConsumerGroupChangeDescription.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.change.handlers.consumer.DeleteConsumerGroupHandler.class - [JAR]

io.streamthoughts.jikkou.kafka.reporter.ce

├─ io.streamthoughts.jikkou.kafka.reporter.ce.CloudEventAttributes.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.reporter.ce.CloudEventEntity.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.reporter.ce.CloudEventEntityBuilder.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.reporter.ce.CloudEventExtension.class - [JAR]

├─ io.streamthoughts.jikkou.kafka.reporter.ce.package-info.class - [JAR]

io.streamthoughts.jikkou.kafka.action

├─ io.streamthoughts.jikkou.kafka.action.KafkaConsumerGroupsResetOffsets.class - [JAR]