实例介绍
使用sbt编译的kafka manager 2.0.0.2版本,请随意拿走。没有找到相关的编译版本,费了九牛二虎之力改了配置源也没能编译成功,无奈买了代理才完成编译,还请留下一积分养家糊口。
【实例截图】
【核心代码】
6e87f234-deec-4e9b-8183-50edc536155a
└── kafka-manager-2.0.0.2
├── bin
│ ├── kafka-manager
│ ├── kafka-manager.bat
│ ├── kafka_manager_utils_one-10_log-config
│ ├── kafka_manager_utils_one-10_log-config.bat
│ ├── kafka_manager_utils_two-00_log-config
│ ├── kafka_manager_utils_two-00_log-config.bat
│ ├── kafka_manager_utils_zero-10_log-config
│ ├── kafka_manager_utils_zero-10_log-config.bat
│ ├── kafka_manager_utils_zero-11_log-config
│ ├── kafka_manager_utils_zero-11_log-config.bat
│ ├── kafka_manager_utils_zero-90_log-config
│ └── kafka_manager_utils_zero-90_log-config.bat
├── conf
│ ├── application.conf
│ ├── consumer.properties
│ ├── logback.xml
│ ├── logger.xml
│ └── routes
├── lib
│ ├── ch.qos.logback.logback-classic-1.2.3.jar
│ ├── ch.qos.logback.logback-core-1.2.3.jar
│ ├── com.101tec.zkclient-0.11.jar
│ ├── com.adrianhurt.play-bootstrap_2.12-1.4-P26-B4.jar
│ ├── com.adrianhurt.play-bootstrap-core_2.12-1.4-P26.jar
│ ├── com.beachape.enumeratum_2.12-1.5.13.jar
│ ├── com.beachape.enumeratum-macros_2.12-1.5.9.jar
│ ├── com.fasterxml.jackson.core.jackson-annotations-2.9.0.jar
│ ├── com.fasterxml.jackson.core.jackson-core-2.9.8.jar
│ ├── com.fasterxml.jackson.core.jackson-databind-2.9.8.jar
│ ├── com.fasterxml.jackson.datatype.jackson-datatype-jdk8-2.9.8.jar
│ ├── com.fasterxml.jackson.datatype.jackson-datatype-jsr310-2.8.11.jar
│ ├── com.github.ben-manes.caffeine.caffeine-2.6.2.jar
│ ├── com.github.luben.zstd-jni-1.3.8-1.jar
│ ├── com.google.code.findbugs.jsr305-3.0.2.jar
│ ├── com.google.errorprone.error_prone_annotations-2.1.3.jar
│ ├── com.google.guava.guava-23.6.1-jre.jar
│ ├── com.google.j2objc.j2objc-annotations-1.1.jar
│ ├── commons-codec.commons-codec-1.11.jar
│ ├── com.thoughtworks.paranamer.paranamer-2.8.jar
│ ├── com.typesafe.akka.akka-actor_2.12-2.5.19.jar
│ ├── com.typesafe.akka.akka-http-core_2.12-10.0.15.jar
│ ├── com.typesafe.akka.akka-parsing_2.12-10.0.15.jar
│ ├── com.typesafe.akka.akka-protobuf_2.12-2.5.19.jar
│ ├── com.typesafe.akka.akka-slf4j_2.12-2.5.19.jar
│ ├── com.typesafe.akka.akka-stream_2.12-2.5.19.jar
│ ├── com.typesafe.config-1.3.3.jar
│ ├── com.typesafe.play.build-link-2.6.21.jar
│ ├── com.typesafe.play.filters-helpers_2.12-2.6.21.jar
│ ├── com.typesafe.play.play_2.12-2.6.21.jar
│ ├── com.typesafe.play.play-akka-http-server_2.12-2.6.21.jar
│ ├── com.typesafe.play.play-exceptions-2.6.21.jar
│ ├── com.typesafe.play.play-functional_2.12-2.6.12.jar
│ ├── com.typesafe.play.play-json_2.12-2.6.12.jar
│ ├── com.typesafe.play.play-logback_2.12-2.6.21.jar
│ ├── com.typesafe.play.play-netty-utils-2.6.21.jar
│ ├── com.typesafe.play.play-server_2.12-2.6.21.jar
│ ├── com.typesafe.play.play-streams_2.12-2.6.21.jar
│ ├── com.typesafe.play.twirl-api_2.12-1.3.15.jar
│ ├── com.typesafe.scala-logging.scala-logging_2.12-3.9.0.jar
│ ├── com.typesafe.ssl-config-core_2.12-0.3.6.jar
│ ├── com.unboundid.unboundid-ldapsdk-4.0.9.jar
│ ├── com.yammer.metrics.metrics-core-2.2.0.jar
│ ├── io.jsonwebtoken.jjwt-0.7.0.jar
│ ├── io.netty.netty-3.10.6.Final.jar
│ ├── javax.activation.javax.activation-api-1.2.0.jar
│ ├── javax.inject.javax.inject-1.jar
│ ├── javax.transaction.jta-1.1.jar
│ ├── javax.xml.bind.jaxb-api-2.3.1.jar
│ ├── jline.jline-0.9.94.jar
│ ├── joda-time.joda-time-2.9.9.jar
│ ├── kafka-manager.kafka-manager-2.0.0.2-assets.jar
│ ├── kafka-manager.kafka-manager-2.0.0.2-sans-externalized.jar
│ ├── net.sf.jopt-simple.jopt-simple-5.0.4.jar
│ ├── org.apache.commons.commons-compress-1.9.jar
│ ├── org.apache.commons.commons-lang3-3.6.jar
│ ├── org.apache.curator.curator-client-2.12.0.jar
│ ├── org.apache.curator.curator-framework-2.12.0.jar
│ ├── org.apache.curator.curator-recipes-2.12.0.jar
│ ├── org.apache.kafka.connect-api-2.2.0.jar
│ ├── org.apache.kafka.connect-json-2.2.0.jar
│ ├── org.apache.kafka.kafka_2.12-2.2.0.jar
│ ├── org.apache.kafka.kafka-clients-2.2.0.jar
│ ├── org.apache.kafka.kafka-streams-2.2.0.jar
│ ├── org.apache.yetus.audience-annotations-0.5.0.jar
│ ├── org.apache.zookeeper.zookeeper-3.4.13.jar
│ ├── org.checkerframework.checker-compat-qual-2.0.0.jar
│ ├── org.clapper.grizzled-slf4j_2.12-1.3.3.jar
│ ├── org.codehaus.mojo.animal-sniffer-annotations-1.14.jar
│ ├── org.json4s.json4s-ast_2.12-3.6.5.jar
│ ├── org.json4s.json4s-core_2.12-3.6.5.jar
│ ├── org.json4s.json4s-jackson_2.12-3.6.5.jar
│ ├── org.json4s.json4s-scalap_2.12-3.6.5.jar
│ ├── org.json4s.json4s-scalaz_2.12-3.6.5.jar
│ ├── org.lz4.lz4-java-1.5.0.jar
│ ├── org.reactivestreams.reactive-streams-1.0.2.jar
│ ├── org.rocksdb.rocksdbjni-5.15.10.jar
│ ├── org.scala-lang.modules.scala-java8-compat_2.12-0.8.0.jar
│ ├── org.scala-lang.modules.scala-parser-combinators_2.12-1.0.7.jar
│ ├── org.scala-lang.modules.scala-xml_2.12-1.0.6.jar
│ ├── org.scala-lang.scala-library-2.12.8.jar
│ ├── org.scala-lang.scala-reflect-2.12.8.jar
│ ├── org.scalaz.scalaz-core_2.12-7.2.27.jar
│ ├── org.slf4j.jcl-over-slf4j-1.7.25.jar
│ ├── org.slf4j.jul-to-slf4j-1.7.25.jar
│ ├── org.slf4j.log4j-over-slf4j-1.7.25.jar
│ ├── org.slf4j.slf4j-api-1.7.25.jar
│ ├── org.typelevel.macro-compat_2.12-1.1.1.jar
│ ├── org.webjars.backbonejs-1.3.3.jar
│ ├── org.webjars.bootstrap-4.3.1.jar
│ ├── org.webjars.dustjs-linkedin-2.7.2.jar
│ ├── org.webjars.jquery-3.3.1-2.jar
│ ├── org.webjars.json-20121008-1.jar
│ ├── org.webjars.octicons-4.3.0.jar
│ ├── org.webjars.popper.js-1.14.3.jar
│ ├── org.webjars.requirejs-2.3.5.jar
│ ├── org.webjars.underscorejs-1.9.0.jar
│ ├── org.webjars.webjars-locator-0.32-1.jar
│ ├── org.webjars.webjars-locator-core-0.35.jar
│ ├── org.webjars.webjars-play_2.12-2.6.3.jar
│ └── org.xerial.snappy.snappy-java-1.1.7.2.jar
├── README.md
└── share
└── doc
└── api
├── akka
│ ├── index.html
│ └── pattern
│ └── index.html
├── controllers
│ ├── api
│ │ ├── index.html
│ │ ├── javascript
│ │ │ ├── index.html
│ │ │ └── ReverseKafkaStateCheck.html
│ │ ├── KafkaStateCheck.html
│ │ ├── ReverseKafkaStateCheck.html
│ │ └── routes.html
│ ├── ApiHealth.html
│ ├── Application.html
│ ├── AuthenticationConfig.html
│ ├── Authenticator.html
│ ├── AuthType.html
│ ├── BasicAuth$.html
│ ├── BasicAuthenticationConfig.html
│ ├── BasicAuthenticationFilter$.html
│ ├── BasicAuthenticationFilterConfiguration$.html
│ ├── BasicAuthenticationFilterConfiguration.html
│ ├── BasicAuthenticationFilter.html
│ ├── BasicAuthenticator$.html
│ ├── BasicAuthenticator.html
│ ├── Cluster.html
│ ├── Consumer.html
│ ├── index.html
│ ├── javascript
│ │ ├── index.html
│ │ ├── ReverseApiHealth.html
│ │ ├── ReverseApplication.html
│ │ ├── ReverseAssets.html
│ │ ├── ReverseCluster.html
│ │ ├── ReverseConsumer.html
│ │ ├── ReverseLogkafka.html
│ │ ├── ReversePreferredReplicaElection.html
│ │ ├── ReverseReassignPartitions.html
│ │ └── ReverseTopic.html
│ ├── KafkaManagerContext.html
│ ├── LDAPAuth$.html
│ ├── LDAPAuthenticationConfig.html
│ ├── LDAPAuthenticator$.html
│ ├── LDAPAuthenticator.html
│ ├── Logkafka.html
│ ├── PreferredReplicaElection.html
│ ├── ReassignPartitions.html
│ ├── ReverseApiHealth.html
│ ├── ReverseApplication.html
│ ├── ReverseAssets.html
│ ├── ReverseCluster.html
│ ├── ReverseConsumer.html
│ ├── ReverseLogkafka.html
│ ├── ReversePreferredReplicaElection.html
│ ├── ReverseReassignPartitions.html
│ ├── ReverseTopic.html
│ ├── routes.html
│ └── Topic.html
├── features
│ ├── ApplicationFeature$.html
│ ├── ApplicationFeature.html
│ ├── ApplicationFeatures$.html
│ ├── ApplicationFeatures.html
│ ├── index.html
│ ├── KMBootstrapClusterConfigFeature$.html
│ ├── KMClusterManagerFeature$.html
│ ├── KMPreferredReplicaElectionFeature$.html
│ ├── KMReassignPartitionsFeature$.html
│ └── KMTopicManagerFeature$.html
├── index.html
├── index.js
├── kafka
│ ├── index.html
│ └── manager
│ ├── actor
│ │ ├── cluster
│ │ │ ├── BrokerViewCacheActorConfig.html
│ │ │ ├── BrokerViewCacheActor.html
│ │ │ ├── ClusterManagerActor$.html
│ │ │ ├── ClusterManagerActorConfig.html
│ │ │ ├── ClusterManagerActor.html
│ │ │ ├── ConsumerInstanceSubscriptions$.html
│ │ │ ├── ConsumerInstanceSubscriptions.html
│ │ │ ├── index.html
│ │ │ ├── KafkaAdminClientActorConfig.html
│ │ │ ├── KafkaAdminClientActor.html
│ │ │ ├── KafkaAdminClient.html
│ │ │ ├── KafkaCommandActorConfig.html
│ │ │ ├── KafkaCommandActor.html
│ │ │ ├── KafkaManagedOffsetCache$.html
│ │ │ ├── KafkaManagedOffsetCacheConfig$.html
│ │ │ ├── KafkaManagedOffsetCacheConfig.html
│ │ │ ├── KafkaManagedOffsetCache.html
│ │ │ ├── KafkaStateActor$KafkaTopicOffsetGetter.html
│ │ │ ├── KafkaStateActorConfig.html
│ │ │ ├── KafkaStateActor.html
│ │ │ ├── OffsetCacheActive.html
│ │ │ ├── OffsetCache.html
│ │ │ ├── OffsetCachePassive.html
│ │ │ ├── package$$TryLogErrorHelper.html
│ │ │ └── PartitionOffsetRequestInfo.html
│ │ ├── DeleteClusterActorConfig.html
│ │ ├── DeleteClusterActor.html
│ │ ├── index.html
│ │ ├── KafkaManagerActor$.html
│ │ ├── KafkaManagerActorConfig.html
│ │ └── KafkaManagerActor.html
│ ├── ApiError$.html
│ ├── ApiError.html
│ ├── base
│ │ ├── BaseActor.html
│ │ ├── BaseCommandActor.html
│ │ ├── BaseQueryActor.html
│ │ ├── BaseQueryCommandActor.html
│ │ ├── BaseZkPath.html
│ │ ├── cluster
│ │ │ ├── BaseClusterActor.html
│ │ │ ├── BaseClusterCommandActor.html
│ │ │ ├── BaseClusterQueryActor.html
│ │ │ ├── BaseClusterQueryCommandActor.html
│ │ │ └── index.html
│ │ ├── CuratorAwareActor.html
│ │ ├── index.html
│ │ ├── LongRunningPoolActor.html
│ │ └── LongRunningPoolConfig.html
│ ├── BrokerListExtended.html
│ ├── ConsumerListExtended.html
│ ├── features
│ │ ├── ClusterFeature$.html
│ │ ├── ClusterFeature.html
│ │ ├── ClusterFeatures$.html
│ │ ├── ClusterFeatures.html
│ │ ├── index.html
│ │ ├── KMDeleteTopicFeature$.html
│ │ ├── KMDisplaySizeFeature$.html
│ │ ├── KMFeature.html
│ │ ├── KMJMXMetricsFeature$.html
│ │ ├── KMLogKafkaFeature$.html
│ │ └── KMPollConsumersFeature$.html
│ ├── index.html
│ ├── jmx
│ │ ├── FormatMetric$.html
│ │ ├── GaugeMetric.html
│ │ ├── index.html
│ │ ├── KafkaJMX$.html
│ │ ├── KafkaMetrics$.html
│ │ ├── LogInfo.html
│ │ ├── LogSegment.html
│ │ ├── MeterMetric.html
│ │ ├── OSMetric.html
│ │ └── SegmentsMetric.html
│ ├── KafkaManager$.html
│ ├── KafkaManager.html
│ ├── logkafka
│ │ ├── index.html
│ │ ├── LogkafkaCommandActorConfig.html
│ │ ├── LogkafkaCommandActor.html
│ │ ├── LogkafkaStateActor.html
│ │ ├── LogkafkaViewCacheActorConfig.html
│ │ └── LogkafkaViewCacheActor.html
│ ├── LogkafkaListExtended.html
│ ├── model
│ │ ├── ActorModel$$ActorErrorResponse.html
│ │ ├── ActorModel$$ActorRequest.html
│ │ ├── ActorModel$$ActorResponse.html
│ │ ├── ActorModel$$BrokerClusterStats.html
│ │ ├── ActorModel$$BrokerIdentity$.html
│ │ ├── ActorModel$$BrokerIdentity.html
│ │ ├── ActorModel$$BrokerList.html
│ │ ├── ActorModel$$BrokerMessagesPerSecCount.html
│ │ ├── ActorModel$$BrokerMetrics$.html
│ │ ├── ActorModel$$BrokerMetrics.html
│ │ ├── ActorModel$$BrokerTopicInfo.html
│ │ ├── ActorModel$$BrokerTopicPartitions.html
│ │ ├── ActorModel$$BVForceUpdate$.html
│ │ ├── ActorModel$$BVGetBrokerMetrics$.html
│ │ ├── ActorModel$$BVGetBrokerTopicPartitionSizes.html
│ │ ├── ActorModel$$BVGetConsumerIdentities$.html
│ │ ├── ActorModel$$BVGetTopicConsumerMap$.html
│ │ ├── ActorModel$$BVGetTopicIdentities$.html
│ │ ├── ActorModel$$BVGetTopicMetrics.html
│ │ ├── ActorModel$$BVGetView.html
│ │ ├── ActorModel$$BVGetViews$.html
│ │ ├── ActorModel$$BVRequest.html
│ │ ├── ActorModel$$BVUpdateBrokerMetrics.html
│ │ ├── ActorModel$$BVUpdateBrokerTopicPartitionSizes.html
│ │ ├── ActorModel$$BVUpdateTopicMetricsForBroker.html
│ │ ├── ActorModel$$BVView.html
│ │ ├── ActorModel$$CMAddMultipleTopicsPartitions.html
│ │ ├── ActorModel$$CMAddTopicPartitions.html
│ │ ├── ActorModel$$CMCommandResult.html
│ │ ├── ActorModel$$CMCommandResults.html
│ │ ├── ActorModel$$CMConsumedTopic.html
│ │ ├── ActorModel$$CMConsumerIdentity.html
│ │ ├── ActorModel$$CMCreateLogkafka.html
│ │ ├── ActorModel$$CMCreateTopic.html
│ │ ├── ActorModel$$CMDeleteLogkafka.html
│ │ ├── ActorModel$$CMDeleteTopic.html
│ │ ├── ActorModel$$CMGeneratePartitionAssignments.html
│ │ ├── ActorModel$$CMGetClusterContext$.html
│ │ ├── ActorModel$$CMGetConsumedTopicState.html
│ │ ├── ActorModel$$CMGetConsumerIdentity.html
│ │ ├── ActorModel$$CMGetGeneratedPartitionAssignments.html
│ │ ├── ActorModel$$CMGetLogkafkaIdentity.html
│ │ ├── ActorModel$$CMGetTopicIdentity.html
│ │ ├── ActorModel$$CMGetView$.html
│ │ ├── ActorModel$$CMLogkafkaIdentity.html
│ │ ├── ActorModel$$CMManualPartitionAssignments.html
│ │ ├── ActorModel$$CMRunPreferredLeaderElection.html
│ │ ├── ActorModel$$CMRunReassignPartition.html
│ │ ├── ActorModel$$CMShutdown$.html
│ │ ├── ActorModel$$CMTopicIdentity.html
│ │ ├── ActorModel$$CMUpdateLogkafkaConfig.html
│ │ ├── ActorModel$$CMUpdateTopicConfig.html
│ │ ├── ActorModel$$CMView.html
│ │ ├── ActorModel$$CommandRequest.html
│ │ ├── ActorModel$$CommandResponse.html
│ │ ├── ActorModel$$ConsumedTopicDescription.html
│ │ ├── ActorModel$$ConsumedTopicState$.html
│ │ ├── ActorModel$$ConsumedTopicState.html
│ │ ├── ActorModel$$ConsumerDescription.html
│ │ ├── ActorModel$$ConsumerDescriptions.html
│ │ ├── ActorModel$$ConsumerIdentity$.html
│ │ ├── ActorModel$$ConsumerIdentity.html
│ │ ├── ActorModel$$ConsumerList.html
│ │ ├── ActorModel$$ConsumerNameAndType.html
│ │ ├── ActorModel$$ConsumerType$.html
│ │ ├── ActorModel$$ConsumerType.html
│ │ ├── ActorModel$$DCUpdateState$.html
│ │ ├── ActorModel$$GeneratedPartitionAssignments.html
│ │ ├── ActorModel$$KafkaManagedConsumer$.html
│ │ ├── ActorModel$$KAGetGroupSummary.html
│ │ ├── ActorModel$$KARequest.html
│ │ ├── ActorModel$$KCAddMultipleTopicsPartitions.html
│ │ ├── ActorModel$$KCAddTopicPartitions.html
│ │ ├── ActorModel$$KCCommandResult.html
│ │ ├── ActorModel$$KCCreateTopic.html
│ │ ├── ActorModel$$KCDeleteTopic.html
│ │ ├── ActorModel$$KCPreferredReplicaLeaderElection.html
│ │ ├── ActorModel$$KCReassignPartition.html
│ │ ├── ActorModel$$KCUpdateTopicConfig.html
│ │ ├── ActorModel$$KMAddCluster.html
│ │ ├── ActorModel$$KMClusterCommandRequest.html
│ │ ├── ActorModel$$KMClusterConfigResult.html
│ │ ├── ActorModel$$KMClusterList.html
│ │ ├── ActorModel$$KMClusterQueryRequest.html
│ │ ├── ActorModel$$KMCommandResult.html
│ │ ├── ActorModel$$KMDeleteCluster.html
│ │ ├── ActorModel$$KMDisableCluster.html
│ │ ├── ActorModel$$KMEnableCluster.html
│ │ ├── ActorModel$$KMGetActiveClusters$.html
│ │ ├── ActorModel$$KMGetAllClusters$.html
│ │ ├── ActorModel$$KMGetClusterConfig.html
│ │ ├── ActorModel$$KMPruneClusters$.html
│ │ ├── ActorModel$$KMQueryResult.html
│ │ ├── ActorModel$$KMShutdown$.html
│ │ ├── ActorModel$$KMShutdownComplete$.html
│ │ ├── ActorModel$$KMUpdateCluster.html
│ │ ├── ActorModel$$KMUpdateState$.html
│ │ ├── ActorModel$$KSEndPreferredLeaderElection.html
│ │ ├── ActorModel$$KSEndReassignPartition.html
│ │ ├── ActorModel$$KSGetAllConsumerDescriptions.html
│ │ ├── ActorModel$$KSGetAllTopicDescriptions.html
│ │ ├── ActorModel$$KSGetBrokers$.html
│ │ ├── ActorModel$$KSGetBrokerState.html
│ │ ├── ActorModel$$KSGetConsumedTopicDescription.html
│ │ ├── ActorModel$$KSGetConsumerDescription.html
│ │ ├── ActorModel$$KSGetConsumerDescriptions.html
│ │ ├── ActorModel$$KSGetConsumers$.html
│ │ ├── ActorModel$$KSGetPreferredLeaderElection$.html
│ │ ├── ActorModel$$KSGetReassignPartition$.html
│ │ ├── ActorModel$$KSGetTopicConfig.html
│ │ ├── ActorModel$$KSGetTopicDescription.html
│ │ ├── ActorModel$$KSGetTopicDescriptions.html
│ │ ├── ActorModel$$KSGetTopics$.html
│ │ ├── ActorModel$$KSGetTopicsLastUpdateMillis$.html
│ │ ├── ActorModel$$KSRequest.html
│ │ ├── ActorModel$$KSUpdatePreferredLeaderElection.html
│ │ ├── ActorModel$$KSUpdateReassignPartition.html
│ │ ├── ActorModel$$LKCCommandResult.html
│ │ ├── ActorModel$$LKCCreateLogkafka.html
│ │ ├── ActorModel$$LKCDeleteLogkafka.html
│ │ ├── ActorModel$$LKCUpdateLogkafkaConfig.html
│ │ ├── ActorModel$$LKSGetAllLogkafkaClients.html
│ │ ├── ActorModel$$LKSGetAllLogkafkaConfigs.html
│ │ ├── ActorModel$$LKSGetLogkafkaClient.html
│ │ ├── ActorModel$$LKSGetLogkafkaClients.html
│ │ ├── ActorModel$$LKSGetLogkafkaConfig.html
│ │ ├── ActorModel$$LKSGetLogkafkaConfigs.html
│ │ ├── ActorModel$$LKSGetLogkafkaLogkafkaIds$.html
│ │ ├── ActorModel$$LKSRequest.html
│ │ ├── ActorModel$$LKVForceUpdate$.html
│ │ ├── ActorModel$$LKVGetLogkafkaIdentities$.html
│ │ ├── ActorModel$$LKVRequest.html
│ │ ├── ActorModel$$LogkafkaClient.html
│ │ ├── ActorModel$$LogkafkaClients.html
│ │ ├── ActorModel$$LogkafkaConfig.html
│ │ ├── ActorModel$$LogkafkaConfigs.html
│ │ ├── ActorModel$$LogkafkaIdentity$.html
│ │ ├── ActorModel$$LogkafkaIdentity.html
│ │ ├── ActorModel$$LogkafkaLogkafkaIdList.html
│ │ ├── ActorModel$$PartitionOffsetsCapture$.html
│ │ ├── ActorModel$$PartitionOffsetsCapture.html
│ │ ├── ActorModel$$PreferredReplicaElection.html
│ │ ├── ActorModel$$QueryRequest.html
│ │ ├── ActorModel$$QueryResponse.html
│ │ ├── ActorModel$$ReassignPartitions.html
│ │ ├── ActorModel$$TopicConfig.html
│ │ ├── ActorModel$$TopicDescription.html
│ │ ├── ActorModel$$TopicDescriptions.html
│ │ ├── ActorModel$$TopicIdentity$.html
│ │ ├── ActorModel$$TopicIdentity.html
│ │ ├── ActorModel$$TopicList.html
│ │ ├── ActorModel$$TopicPartitionIdentity$.html
│ │ ├── ActorModel$$TopicPartitionIdentity.html
│ │ ├── ActorModel$$ZKManagedConsumer$.html
│ │ ├── ActorModel$.html
│ │ ├── ClusterConfig$.html
│ │ ├── ClusterConfig.html
│ │ ├── ClusterContext.html
│ │ ├── ClusterTuning$.html
│ │ ├── ClusterTuning.html
│ │ ├── CuratorConfig.html
│ │ ├── index.html
│ │ ├── Kafka_0_10_0_0$.html
│ │ ├── Kafka_0_10_0_1$.html
│ │ ├── Kafka_0_10_1_0$.html
│ │ ├── Kafka_0_10_1_1$.html
│ │ ├── Kafka_0_10_2_0$.html
│ │ ├── Kafka_0_10_2_1$.html
│ │ ├── Kafka_0_11_0_0$.html
│ │ ├── Kafka_0_11_0_2$.html
│ │ ├── Kafka_0_8_1_1$.html
│ │ ├── Kafka_0_8_2_0$.html
│ │ ├── Kafka_0_8_2_1$.html
│ │ ├── Kafka_0_8_2_2$.html
│ │ ├── Kafka_0_9_0_0$.html
│ │ ├── Kafka_0_9_0_1$.html
│ │ ├── Kafka_1_0_0$.html
│ │ ├── Kafka_1_0_1$.html
│ │ ├── Kafka_1_1_0$.html
│ │ ├── Kafka_1_1_1$.html
│ │ ├── Kafka_2_0_0$.html
│ │ ├── Kafka_2_1_0$.html
│ │ ├── Kafka_2_1_1$.html
│ │ ├── Kafka_2_2_0$.html
│ │ ├── KafkaVersion$.html
│ │ ├── KafkaVersion.html
│ │ ├── PLAINTEXT$.html
│ │ ├── PLAINTEXTSASL$.html
│ │ ├── SASLmechanism$.html
│ │ ├── SASL_MECHANISM_GSSAPI$.html
│ │ ├── SASLmechanism.html
│ │ ├── SASL_MECHANISM_PLAIN$.html
│ │ ├── SASL_MECHANISM_SCRAM256$.html
│ │ ├── SASL_MECHANISM_SCRAM512$.html
│ │ ├── SASL_PLAINTEXT$.html
│ │ ├── SASL_SSL$.html
│ │ ├── SecurityProtocol$.html
│ │ ├── SecurityProtocol.html
│ │ └── SSL$.html
│ ├── TopicListExtended.html
│ └── utils
│ ├── AdminUtils.html
│ ├── FiniteQueue.html
│ ├── index.html
│ ├── Logkafka$.html
│ ├── logkafka81
│ │ ├── Defaults$.html
│ │ ├── index.html
│ │ ├── LogConfig$.html
│ │ ├── LogConfig.html
│ │ ├── LogkafkaConfigErrors$$InvalidLineDelimiter.html
│ │ ├── LogkafkaConfigErrors$$InvalidRegexFilterPattern.html
│ │ ├── LogkafkaConfigErrors$$InvalidRegexFilterPatternLength.html
│ │ └── LogkafkaConfigErrors$.html
│ ├── logkafka82
│ │ ├── Defaults$.html
│ │ ├── index.html
│ │ ├── LogConfig$.html
│ │ ├── LogConfig.html
│ │ ├── LogkafkaConfigErrors$$InvalidLineDelimiter.html
│ │ ├── LogkafkaConfigErrors$$InvalidRegexFilterPattern.html
│ │ ├── LogkafkaConfigErrors$$InvalidRegexFilterPatternLength.html
│ │ └── LogkafkaConfigErrors$.html
│ ├── LogkafkaAdminUtils.html
│ ├── LogkafkaErrors$$HostnameEmpty.html
│ ├── LogkafkaErrors$$HostnameIsLocalhost.html
│ ├── LogkafkaErrors$$HostnameNotExists.html
│ ├── LogkafkaErrors$$IllegalCharacterInHostname.html
│ ├── LogkafkaErrors$$IllegalCharacterInLogkafkaId.html
│ ├── LogkafkaErrors$$IllegalCharacterInPath.html
│ ├── LogkafkaErrors$$InvalidHostname.html
│ ├── LogkafkaErrors$$InvalidHostnameLength.html
│ ├── LogkafkaErrors$$InvalidLogkafkaId.html
│ ├── LogkafkaErrors$$InvalidLogkafkaIdLength.html
│ ├── LogkafkaErrors$$InvalidLogPath.html
│ ├── LogkafkaErrors$$InvalidLogPathLength.html
│ ├── LogkafkaErrors$$LogkafkaIdEmpty.html
│ ├── LogkafkaErrors$$LogkafkaIdNotExists.html
│ ├── LogkafkaErrors$$LogPathEmpty.html
│ ├── LogkafkaErrors$$LogPathNotAbsolute.html
│ ├── LogkafkaErrors$.html
│ ├── LogkafkaNewConfigs$.html
│ ├── LogkafkaNewConfigs.html
│ ├── LogkafkaZkUtils$.html
│ ├── one10
│ │ ├── BaseKey.html
│ │ ├── CommitRecordMetadataAndOffset.html
│ │ ├── Defaults$.html
│ │ ├── GroupMetadata$.html
│ │ ├── GroupMetadata.html
│ │ ├── GroupMetadataKey.html
│ │ ├── GroupMetadataManager$$GroupMetadataMessageFormatter.html
│ │ ├── GroupMetadataManager$$OffsetsMessageFormatter.html
│ │ ├── GroupMetadataManager$.html
│ │ ├── GroupOverview.html
│ │ ├── GroupTopicPartition.html
│ │ ├── index.html
│ │ ├── LogConfig$.html
│ │ ├── LogConfig.html
│ │ ├── MemberMetadata$.html
│ │ ├── MemberMetadata.html
│ │ └── OffsetKey.html
│ ├── package$$LongFormatted.html
│ ├── repeatWithIndex$.html
│ ├── Topic$.html
│ ├── TopicConfigs$.html
│ ├── TopicConfigs.html
│ ├── TopicErrors$$CannotAddZeroPartitions.html
│ ├── TopicErrors$$DuplicateReplicaAssignment.html
│ ├── TopicErrors$$FailedToAddNewPartitions.html
│ ├── TopicErrors$$IllegalCharacterInName.html
│ ├── TopicErrors$$InconsistentPartitionReplicas.html
│ ├── TopicErrors$$InvalidTopicLength.html
│ ├── TopicErrors$$InvalidTopicName.html
│ ├── TopicErrors$$NoReadVersionFound.html
│ ├── TopicErrors$$PartitionsGreaterThanZero.html
│ ├── TopicErrors$$ReplicationGreaterThanNumBrokers.html
│ ├── TopicErrors$$ReplicationGreaterThanZero.html
│ ├── TopicErrors$$TopicAlreadyExists.html
│ ├── TopicErrors$$TopicDoesNotExist.html
│ ├── TopicErrors$$TopicNameEmpty.html
│ ├── TopicErrors$.html
│ ├── two00
│ │ ├── Defaults$.html
│ │ ├── index.html
│ │ ├── LogConfig$.html
│ │ └── LogConfig.html
│ ├── UtilError.html
│ ├── UtilException.html
│ ├── zero10
│ │ ├── Defaults$.html
│ │ ├── index.html
│ │ ├── LogConfig$.html
│ │ └── LogConfig.html
│ ├── zero11
│ │ ├── Defaults$.html
│ │ ├── index.html
│ │ ├── LogConfig$.html
│ │ └── LogConfig.html
│ ├── zero81
│ │ ├── ForceOnReplicationOutOfSync$.html
│ │ ├── ForceReassignmentCommand.html
│ │ ├── index.html
│ │ ├── LogConfig$.html
│ │ ├── LogConfig.html
│ │ ├── PreferredLeaderElectionErrors$$ElectionAlreadyInProgress.html
│ │ ├── PreferredLeaderElectionErrors$$ElectionSetEmptyOnRead.html
│ │ ├── PreferredLeaderElectionErrors$$ElectionSetEmptyOnWrite.html
│ │ ├── PreferredLeaderElectionErrors$$UnhandledException.html
│ │ ├── PreferredLeaderElectionErrors$.html
│ │ ├── PreferredReplicaLeaderElectionCommand$.html
│ │ ├── ReassignPartitionCommand$.html
│ │ ├── ReassignPartitionCommand.html
│ │ ├── ReassignPartitionErrors$$DuplicateFoundInReplicaSetForPartition.html
│ │ ├── ReassignPartitionErrors$$FailedToReassignPartitionReplicas.html
│ │ ├── ReassignPartitionErrors$$MissingReplicaSetForPartition.html
│ │ ├── ReassignPartitionErrors$$NoValidAssignments.html
│ │ ├── ReassignPartitionErrors$$PartitionsOutOfSync.html
│ │ ├── ReassignPartitionErrors$$ReassignmentAlreadyInProgress.html
│ │ ├── ReassignPartitionErrors$$ReassignmentDataEmptyForTopic.html
│ │ ├── ReassignPartitionErrors$$ReplicationOutOfSync.html
│ │ └── ReassignPartitionErrors$.html
│ ├── zero82
│ │ ├── Defaults$.html
│ │ ├── index.html
│ │ ├── LogConfig$.html
│ │ └── LogConfig.html
│ ├── zero90
│ │ ├── Defaults$.html
│ │ ├── GroupMetadata.html
│ │ ├── GroupMetadataManager$.html
│ │ ├── index.html
│ │ ├── LogConfig$.html
│ │ ├── LogConfig.html
│ │ ├── MemberMetadata$.html
│ │ └── MemberMetadata.html
│ └── ZkUtils$.html
├── lib
│ ├── abstract_type.svg
│ ├── class_comp.svg
│ ├── class_diagram.png
│ ├── class.svg
│ ├── diagrams.css
│ ├── diagrams.js
│ ├── index.css
│ ├── index.js
│ ├── jquery.js
│ ├── jquery.mousewheel.min.js
│ ├── jquery.panzoom.min.js
│ ├── lato-v11-latin-100.eot
│ ├── lato-v11-latin-100.ttf
│ ├── lato-v11-latin-100.woff
│ ├── lato-v11-latin-regular.eot
│ ├── lato-v11-latin-regular.ttf
│ ├── lato-v11-latin-regular.woff
│ ├── MaterialIcons-Regular.eot
│ ├── MaterialIcons-Regular.ttf
│ ├── MaterialIcons-Regular.woff
│ ├── modernizr.custom.js
│ ├── object_comp.svg
│ ├── object_comp_trait.svg
│ ├── object_diagram.png
│ ├── object.svg
│ ├── open-sans-v13-latin-400i.eot
│ ├── open-sans-v13-latin-400i.ttf
│ ├── open-sans-v13-latin-400i.woff
│ ├── open-sans-v13-latin-700.eot
│ ├── open-sans-v13-latin-700i.eot
│ ├── open-sans-v13-latin-700i.ttf
│ ├── open-sans-v13-latin-700i.woff
│ ├── open-sans-v13-latin-700.ttf
│ ├── open-sans-v13-latin-700.woff
│ ├── open-sans-v13-latin-regular.eot
│ ├── open-sans-v13-latin-regular.ttf
│ ├── open-sans-v13-latin-regular.woff
│ ├── ownderbg2.gif
│ ├── ownerbg2.gif
│ ├── ownerbg.gif
│ ├── package.svg
│ ├── ref-index.css
│ ├── scheduler.js
│ ├── source-code-pro-v6-latin-700.eot
│ ├── source-code-pro-v6-latin-700.ttf
│ ├── source-code-pro-v6-latin-700.woff
│ ├── source-code-pro-v6-latin-regular.eot
│ ├── source-code-pro-v6-latin-regular.ttf
│ ├── source-code-pro-v6-latin-regular.woff
│ ├── template.css
│ ├── template.js
│ ├── tools.tooltip.js
│ ├── trait_comp.svg
│ ├── trait_diagram.png
│ ├── trait.svg
│ └── type_diagram.png
├── loader
│ ├── ApplicationComponents.html
│ ├── index.html
│ └── KafkaManagerLoader.html
├── models
│ ├── FollowLink.html
│ ├── form
│ │ ├── AddMultipleTopicsPartitions.html
│ │ ├── AddTopicPartitions.html
│ │ ├── BrokerSelect$.html
│ │ ├── BrokerSelect.html
│ │ ├── ClusterOperation$.html
│ │ ├── ClusterOperation.html
│ │ ├── CreateLogkafka.html
│ │ ├── CreateTopic.html
│ │ ├── Delete$.html
│ │ ├── DeleteLogkafka.html
│ │ ├── DeleteTopic.html
│ │ ├── Disable$.html
│ │ ├── Enable$.html
│ │ ├── GenerateAssignment.html
│ │ ├── GenerateMultipleAssignments.html
│ │ ├── index.html
│ │ ├── LKConfig.html
│ │ ├── LogkafkaOperation.html
│ │ ├── Operation$.html
│ │ ├── Operation.html
│ │ ├── PreferredReplicaElectionOperation$.html
│ │ ├── PreferredReplicaElectionOperation.html
│ │ ├── ReadVersion.html
│ │ ├── ReassignPartitionOperation$$ForceRunAssignment$.html
│ │ ├── ReassignPartitionOperation$$RunAssignment$.html
│ │ ├── ReassignPartitionOperation$$UnknownRPO$.html
│ │ ├── ReassignPartitionOperation$.html
│ │ ├── ReassignPartitionOperation.html
│ │ ├── RunElection$.html
│ │ ├── RunMultipleAssignments.html
│ │ ├── TConfig.html
│ │ ├── TopicOperation.html
│ │ ├── TopicSelect$.html
│ │ ├── TopicSelect.html
│ │ ├── Unknown.html
│ │ ├── UnknownLKO.html
│ │ ├── UnknownPREO.html
│ │ ├── UnknownTO.html
│ │ ├── Update$.html
│ │ ├── UpdateLogkafkaConfig.html
│ │ └── UpdateTopicConfig.html
│ ├── index.html
│ └── navigation
│ ├── BreadCrumbs$$BCActive.html
│ ├── BreadCrumbs$$BCDynamicLink.html
│ ├── BreadCrumbs$$BCDynamicMultiNamedLink2.html
│ ├── BreadCrumbs$$BCDynamicMultiNamedLink.html
│ ├── BreadCrumbs$$BCDynamicNamedLink.html
│ ├── BreadCrumbs$$BCDynamicText.html
│ ├── BreadCrumbs$$BCLink.html
│ ├── BreadCrumbs$$BCStaticLink.html
│ ├── BreadCrumbs$$BCText.html
│ ├── BreadCrumbs$$BreadCrumb.html
│ ├── BreadCrumbs$$BreadCrumbRendered.html
│ ├── BreadCrumbs$.html
│ ├── index.html
│ ├── Menu.html
│ ├── Menus.html
│ ├── QuickRoutes$$BaseRoute.html
│ ├── QuickRoutes$$ClusterRoute.html
│ ├── QuickRoutes$$ConsumerRoute.html
│ ├── QuickRoutes$$LogkafkaRoute.html
│ ├── QuickRoutes$$TopicRoute.html
│ └── QuickRoutes$.html
├── router
│ ├── index.html
│ ├── Routes.html
│ └── RoutesPrefix$.html
├── scalaz
│ ├── index.html
│ └── syntax
│ └── index.html
└── views
├── html
│ ├── broker
│ │ ├── brokerList$.html
│ │ ├── brokerListContent$.html
│ │ ├── brokerView$.html
│ │ ├── brokerViewContent$.html
│ │ └── index.html
│ ├── cluster
│ │ ├── addCluster$.html
│ │ ├── clusterList$.html
│ │ ├── clusterView$.html
│ │ ├── clusterViewContent$.html
│ │ ├── configReferences$.html
│ │ ├── index.html
│ │ ├── pendingClusterList$.html
│ │ └── updateCluster$.html
│ ├── common
│ │ ├── brokerMetrics$.html
│ │ ├── expandedBrokerMetrics$.html
│ │ ├── index.html
│ │ ├── resultOfCommand$.html
│ │ ├── resultsOfCommand$.html
│ │ └── shortBrokerMetrics$.html
│ ├── consumer
│ │ ├── consumedTopicView$.html
│ │ ├── consumedTopicViewContent$.html
│ │ ├── consumerList$.html
│ │ ├── consumerListContent$.html
│ │ ├── consumerView$.html
│ │ ├── consumerViewContent$.html
│ │ └── index.html
│ ├── errors
│ │ ├── index.html
│ │ └── onApiError$.html
│ ├── index$.html
│ ├── index.html
│ ├── logkafka
│ │ ├── createLogkafka$.html
│ │ ├── index.html
│ │ ├── logkafkaList$.html
│ │ ├── logkafkaListContent$.html
│ │ ├── logkafkaView$.html
│ │ ├── logkafkaViewContent$.html
│ │ └── updateConfig$.html
│ ├── main$.html
│ ├── navigation
│ │ ├── breadCrumbs$.html
│ │ ├── clusterMenu$.html
│ │ ├── defaultMenu$.html
│ │ ├── index.html
│ │ └── menuNav$.html
│ ├── preferredReplicaElection$.html
│ ├── reassignPartitions$.html
│ └── topic
│ ├── addPartitions$.html
│ ├── addPartitionsToMultipleTopics$.html
│ ├── confirmAssignment$.html
│ ├── confirmMultipleAssignments$.html
│ ├── createTopic$.html
│ ├── index.html
│ ├── manualAssignments$.html
│ ├── runMultipleAssignments$.html
│ ├── topicDeleteConfirm$.html
│ ├── topicList$.html
│ ├── topicListContent$.html
│ ├── topicView$.html
│ ├── topicViewContent$.html
│ └── updateConfig$.html
└── index.html
52 directories, 780 files
标签:
小贴士
感谢您为本站写下的评论,您的评论对其它用户来说具有重要的参考价值,所以请认真填写。
- 类似“顶”、“沙发”之类没有营养的文字,对勤劳贡献的楼主来说是令人沮丧的反馈信息。
- 相信您也不想看到一排文字/表情墙,所以请不要反馈意义不大的重复字符,也请尽量不要纯表情的回复。
- 提问之前请再仔细看一遍楼主的说明,或许是您遗漏了。
- 请勿到处挖坑绊人、招贴广告。既占空间让人厌烦,又没人会搭理,于人于己都无利。
关于好例子网
本站旨在为广大IT学习爱好者提供一个非营利性互相学习交流分享平台。本站所有资源都可以被免费获取学习研究。本站资源来自网友分享,对搜索内容的合法性不具有预见性、识别性、控制性,仅供学习研究,请务必在下载后24小时内给予删除,不得用于其他任何用途,否则后果自负。基于互联网的特殊性,平台无法对用户传输的作品、信息、内容的权属或合法性、安全性、合规性、真实性、科学性、完整权、有效性等进行实质审查;无论平台是否已进行审查,用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。本站所有资源不代表本站的观点或立场,基于网友分享,根据中国法律《信息网络传播权保护条例》第二十二与二十三条之规定,若资源存在侵权或相关问题请联系本站客服人员,点此联系我们。关于更多版权及免责申明参见 版权及免责申明
网友评论
我要评论