企业级消息队列Kafka

视频-企业级消息队列kafka[2.84G]

001.Kafka简介-消息队列.mp4[16.02M]

002.Kafka简介-应用背景.avi[149.50M]

003.消息队列的两种模型.avi[61.59M]

004.Kafka集群搭建.avi[220.15M]

005.Kafka生产者、消费者测试、KafkaTool工具avi.avi[83.29M]

006.Kafka的基准测试.avi[140.64M]

007.JavaAPI-生产者程序开发.avi[165.19M]

008.JavaAPI-消费者程序开发.avi[141.26M]

009.JavaAPI-生产者使用异步方式生产消息.avi[88.91M]

010.Kafka中的重要概念.avi[151.67M]

011.消费者组演示.avi[104.92M]

012.Kafka幂等性.avi[63.45M]

013.Kafka生产者的分区写入策略.avi[97.04M]

014.ConsumerGroupRebalance机制.avi[62.61M]

015.消费者的分区分配策略.avi[130.90M]

016.producer的ACK机制.avi[102.02M]

017.高级API（High-LevelAPI）、低级API（Low-LevelAPI）.avi[66.96M]

018.安装Kafkaegale.avi[180.76M]

019.leader和follower.avi[109.28M]

020.topic中的partition的ar、isr、osr.avi[70.33M]

021.controller介绍与leader选举.avi[87.76M]

022.leader的负载均衡.avi[39.43M]

023.Kafka读写流程.avi[62.01M]

024.Kafka的物理存储.avi[245.00M]

025.Kafka的消息不丢失.avi[143.53M]

026.数据积压.avi[102.73M]

027.日志清理.mp4[25.41M]

资料-企业级消息队列kafka[13.06M]

1.讲义[6.67M]

第1章Kafka入门_v1.2.1.docx[2.74M]

第2章Kafka高级_v1.2.docx[3.94M]

2.图片[540.16K]

第二天[354.23K]

10.消费者消息丢失.png[45.14K]

11.消息重复消费.png[32.72K]

12.消息的Exactly-Once仅被处理一次.png[96.55K]

4.事务编程.png[16.06K]

5.Kafka的乱序问题.png[46.14K]

6.只有leader负责读写也有分布式的意义.png[52.26K]

7.LEO概念.png[18.19K]

9.分区全局offset和局部offset.png[47.17K]

第一天[185.93K]

1.最简单Kafka集群结构图.png[30.02K]

2.事务编程的案例png.png[71.92K]

3.实时数仓.png[83.99K]

3.代码[60.44K]

kafka_java_api[60.44K]

.idea[24.81K]

compiler.xml[0.53K]

encodings.xml[0.23K]

misc.xml[0.51K]

workspace.xml[23.53K]

src[16.99K]

main[16.99K]

java[16.79K]

cn[16.79K]

itcast[16.79K]

kafka[16.79K]

KafkaConsumerTest.java[3.29K]

KafkaProducerTest.java[3.69K]

KafkaProducerTest2.java[3.72K]

TransactionProgram.java[6.08K]

resources[0.20K]

log4j.properties[0.20K]

test

java

target[16.41K]

classes[16.41K]

cn[16.21K]

itcast[16.21K]

kafka[16.21K]

KafkaConsumerTest.class[3.03K]

KafkaProducerTest$1.class[1.65K]

KafkaProducerTest.class[2.08K]

KafkaProducerTest2$1.class[1.66K]

KafkaProducerTest2.class[2.19K]

TransactionProgram.class[5.61K]

log4j.properties[0.20K]

generated-sources

annotations

kafka_java_api.iml[0.08K]

pom.xml[2.15K]

4.资料[5.01M]

Kafka依赖与配置文件[2.21K]

log4j.properties[0.20K]

pom.xml[2.01K]

安装包[5.01M]

kafka-2.4.1-src[4.96M]

.gradle[0.02K]

5.6.2[0.02K]

fileChanges

last-build.bin

fileHashes[0.02K]

fileHashes.lock[0.02K]

vcsMetadata-1

gc.properties

vcs-1

gc.properties

.idea[10.49K]

encodings.xml[0.23K]

gradle.xml[0.63K]

misc.xml[0.26K]

modules.xml[0.27K]

workspace.xml[9.10K]

bin[69.59K]

windows[29.54K]

connect-distributed.bat[1.21K]

connect-standalone.bat[1.21K]

kafka-acls.bat[0.85K]

kafka-broker-api-versions.bat[0.86K]

kafka-configs.bat[0.86K]

kafka-console-consumer.bat[0.90K]

kafka-console-producer.bat[0.90K]

kafka-consumer-groups.bat[0.86K]

kafka-consumer-perf-test.bat[0.92K]

kafka-delegation-tokens.bat[0.86K]

kafka-delete-records.bat[0.86K]

kafka-dump-log.bat[0.86K]

kafka-leader-election.bat[0.86K]

kafka-log-dirs.bat[0.86K]

kafka-mirror-maker.bat[0.85K]

kafka-preferred-replica-election.bat[0.88K]

kafka-producer-perf-test.bat[0.92K]

kafka-reassign-partitions.bat[0.87K]

kafka-replica-verification.bat[0.87K]

kafka-run-class.bat[5.15K]

kafka-server-start.bat[1.34K]

kafka-server-stop.bat[0.97K]

kafka-streams-application-reset.bat[0.95K]

kafka-topics.bat[0.85K]

zookeeper-server-start.bat[1.16K]

zookeeper-server-stop.bat[0.88K]

zookeeper-shell.bat[0.95K]

connect-distributed.sh[1.39K]

connect-mirror-maker.sh[1.36K]

connect-standalone.sh[1.38K]

kafka-acls.sh[0.84K]

kafka-broker-api-versions.sh[0.85K]

kafka-configs.sh[0.84K]

kafka-console-consumer.sh[0.92K]

kafka-console-producer.sh[0.92K]

kafka-consumer-groups.sh[0.85K]

kafka-consumer-perf-test.sh[0.93K]

kafka-delegation-tokens.sh[0.85K]

kafka-delete-records.sh[0.85K]

kafka-dump-log.sh[0.85K]

kafka-leader-election.sh[0.85K]

kafka-log-dirs.sh[0.84K]

kafka-mirror-maker.sh[0.84K]

kafka-preferred-replica-election.sh[0.87K]

kafka-producer-perf-test.sh[0.94K]

kafka-reassign-partitions.sh[0.85K]

kafka-replica-verification.sh[0.85K]

kafka-run-class.sh[9.41K]

kafka-server-start.sh[1.34K]

kafka-server-stop.sh[0.97K]

kafka-streams-application-reset.sh[0.92K]

kafka-topics.sh[0.84K]

kafka-verifiable-consumer.sh[0.94K]

kafka-verifiable-producer.sh[0.94K]

trogdor.sh[1.68K]

zookeeper-security-migration.sh[0.85K]

zookeeper-server-start.sh[1.36K]

zookeeper-server-stop.sh[0.98K]

zookeeper-shell.sh[0.95K]

checkstyle[37.01K]

.scalafmt.conf[0.98K]

checkstyle.xml[4.80K]

import-control.xml[15.85K]

import-control-core.xml[1.88K]

import-control-jmh-benchmarks.xml[1.67K]

java.header[0.78K]

suppressions.xml[11.06K]

clients[4.79M]

src[4.79M]

main[4.63M]

java[4.41M]

org[4.41M]

apache[4.41M]

kafka[4.41M]

clients[1.67M]

admin[414.15K]

internals[8.24K]

AdminMetadataManager.java[8.24K]

AbstractOptions.java[1.58K]

Admin.java[49.81K]

AdminClient.java[1.72K]

AdminClientConfig.java[11.57K]

AlterConfigOp.java[2.81K]

AlterConfigsOptions.java[1.95K]

AlterConfigsResult.java[1.82K]

AlterPartitionReassignmentsOptions.java[1.23K]

AlterPartitionReassignmentsResult.java[2.27K]

AlterReplicaLogDirsOptions.java[1.12K]

AlterReplicaLogDirsResult.java[1.95K]

Config.java[2.33K]

ConfigEntry.java[9.01K]

ConsumerGroupDescription.java[5.21K]

ConsumerGroupListing.java[1.79K]

CreateAclsOptions.java[1.51K]

CreateAclsResult.java[1.83K]

CreateDelegationTokenOptions.java[1.81K]

CreateDelegationTokenResult.java[1.61K]

CreatePartitionsOptions.java[1.65K]

CreatePartitionsResult.java[1.75K]

CreateTopicsOptions.java[1.96K]

CreateTopicsResult.java[5.18K]

DeleteAclsOptions.java[1.52K]

DeleteAclsResult.java[4.28K]

DeleteConsumerGroupOffsetsOptions.java[1.20K]

DeleteConsumerGroupOffsetsResult.java[3.76K]

DeleteConsumerGroupsOptions.java[1.18K]

DeleteConsumerGroupsResult.java[1.81K]

DeletedRecords.java[1.60K]

DeleteRecordsOptions.java[1.16K]

DeleteRecordsResult.java[1.85K]

DeleteTopicsOptions.java[1.52K]

DeleteTopicsResult.java[1.76K]

DescribeAclsOptions.java[1.55K]

DescribeAclsResult.java[1.59K]

DescribeClusterOptions.java[2.02K]

DescribeClusterResult.java[2.82K]

DescribeConfigsOptions.java[1.98K]

DescribeConfigsResult.java[2.92K]

DescribeConsumerGroupsOptions.java[1.57K]

DescribeConsumerGroupsResult.java[2.96K]

DescribeDelegationTokenOptions.java[1.69K]

DescribeDelegationTokenResult.java[1.67K]

DescribeLogDirsOptions.java[1.16K]

DescribeLogDirsResult.java[2.94K]

DescribeReplicaLogDirsOptions.java[1.18K]

DescribeReplicaLogDirsResult.java[5.74K]

DescribeTopicsOptions.java[1.87K]

DescribeTopicsResult.java[2.82K]

ElectLeadersOptions.java[1.16K]

ElectLeadersResult.java[3.05K]

ElectPreferredLeadersOptions.java[1.32K]

ElectPreferredLeadersResult.java[4.64K]

ExpireDelegationTokenOptions.java[1.46K]

ExpireDelegationTokenResult.java[1.51K]

KafkaAdminClient.java[167.48K]

ListConsumerGroupOffsetsOptions.java[1.87K]

ListConsumerGroupOffsetsResult.java[1.84K]

ListConsumerGroupsOptions.java[1.13K]

ListConsumerGroupsResult.java[4.00K]

ListPartitionReassignmentsOptions.java[1.20K]

ListPartitionReassignmentsResult.java[1.60K]

ListTopicsOptions.java[2.05K]

ListTopicsResult.java[2.42K]

MemberAssignment.java[2.23K]

MemberDescription.java[3.54K]

MemberToRemove.java[1.89K]

NewPartitionReassignment.java[1.67K]

NewPartitions.java[3.75K]

NewTopic.java[5.91K]

PartitionReassignment.java[2.33K]

RecordsToDelete.java[2.05K]

RemoveMembersFromConsumerGroupOptions.java[1.61K]

RemoveMembersFromConsumerGroupResult.java[3.78K]

RenewDelegationTokenOptions.java[1.45K]

RenewDelegationTokenResult.java[1.51K]

TopicDescription.java[4.21K]

TopicListing.java[1.69K]

consumer[706.31K]

internals[414.76K]

AbstractCoordinator.java[64.30K]

AbstractPartitionAssignor.java[5.55K]

AbstractStickyAssignor.java[45.46K]

AsyncClient.java[2.93K]

ConsumerCoordinator.java[64.68K]

ConsumerInterceptors.java[4.23K]

ConsumerMetadata.java[3.24K]

ConsumerMetrics.java[1.86K]

ConsumerNetworkClient.java[28.18K]

ConsumerProtocol.java[13.70K]

Fetcher.java[92.79K]

FetcherMetricsRegistry.java[8.97K]

Heartbeat.java[3.63K]

KafkaConsumerMetrics.java[3.71K]

NoAvailableBrokersException.java[1.08K]

NoOpConsumerRebalanceListener.java[1.24K]

OffsetsForLeaderEpochClient.java[5.96K]

PartitionAssignor.java[5.79K]

PartitionAssignorAdapter.java[6.63K]

RequestFuture.java[8.90K]

RequestFutureAdapter.java[1.18K]

RequestFutureListener.java[1.01K]

SubscriptionState.java[39.73K]

CommitFailedException.java[1.98K]

Consumer.java[6.97K]

ConsumerConfig.java[32.00K]

ConsumerGroupMetadata.java[1.56K]

ConsumerInterceptor.java[4.60K]

ConsumerPartitionAssignor.java[9.11K]

ConsumerRebalanceListener.java[14.37K]

ConsumerRecord.java[10.90K]

ConsumerRecords.java[4.61K]

CooperativeStickyAssignor.java[4.66K]

InvalidOffsetException.java[1.36K]

KafkaConsumer.java[136.06K]

LogTruncationException.java[2.06K]

MockConsumer.java[20.05K]

NoOffsetForPartitionException.java[2.26K]

OffsetAndMetadata.java[4.36K]

OffsetAndTimestamp.java[2.73K]

OffsetCommitCallback.java[2.74K]

OffsetOutOfRangeException.java[1.80K]

OffsetResetStrategy.java[0.88K]

RangeAssignor.java[5.45K]

RetriableCommitFailedException.java[1.75K]

RoundRobinAssignor.java[6.83K]

StickyAssignor.java[12.45K]

producer[390.16K]

internals[233.18K]

BufferPool.java[13.34K]

DefaultPartitioner.java[2.87K]

ErrorLoggingCallback.java[2.21K]

FutureRecordMetadata.java[4.57K]

IncompleteBatches.java[1.91K]

ProducerBatch.java[19.39K]

ProduceRequestResult.java[4.14K]

ProducerIdAndEpoch.java[1.50K]

ProducerInterceptors.java[6.65K]

ProducerMetadata.java[4.60K]

ProducerMetrics.java[1.96K]

RecordAccumulator.java[38.77K]

Sender.java[47.92K]

SenderMetricsRegistry.java[10.27K]

StickyPartitionCache.java[3.33K]

TransactionalRequestResult.java[2.79K]

TransactionManager.java[66.95K]

BufferExhaustedException.java[1.28K]

Callback.java[2.68K]

KafkaProducer.java[74.03K]

MockProducer.java[17.10K]

Partitioner.java[2.12K]

Producer.java[3.06K]

ProducerConfig.java[31.04K]

ProducerInterceptor.java[6.06K]

ProducerRecord.java[8.65K]

RecordMetadata.java[5.43K]

RoundRobinPartitioner.java[2.95K]

UniformStickyPartitioner.java[2.58K]

ApiVersion.java[1.98K]

ApiVersions.java[2.65K]

ClientDnsLookup.java[1.38K]

ClientRequest.java[4.28K]

ClientResponse.java[4.49K]

ClientUtils.java[5.88K]

ClusterConnectionStates.java[16.69K]

CommonClientConfigs.java[14.11K]

ConnectionState.java[1.56K]

FetchSessionHandler.java[18.45K]

GroupRebalanceConfig.java[3.97K]

InFlightRequests.java[6.68K]

KafkaClient.java[8.34K]

ManualMetadataUpdater.java[2.68K]

Metadata.java[24.11K]

MetadataCache.java[6.58K]

MetadataUpdater.java[3.56K]

NetworkClient.java[52.76K]

NetworkClientUtils.java[5.35K]

NodeApiVersions.java[9.34K]

RequestCompletionHandler.java[1.15K]

StaleMetadataException.java[1.31K]

common[2.71M]

acl[26.30K]

AccessControlEntry.java[3.53K]

AccessControlEntryData.java[3.36K]

AccessControlEntryFilter.java[4.30K]

AclBinding.java[3.38K]

AclBindingFilter.java[4.58K]

AclOperation.java[4.21K]

AclPermissionType.java[2.94K]

annotation[2.14K]

InterfaceStability.java[2.14K]

cache[5.32K]

Cache.java[1.90K]

LRUCache.java[1.68K]

SynchronizedCache.java[1.75K]

config[169.93K]

internals[6.99K]

BrokerSecurityConfigs.java[6.99K]

provider[6.53K]

ConfigProvider.java[2.98K]

FileConfigProvider.java[3.54K]

types[1.78K]

Password.java[1.78K]

AbstractConfig.java[27.01K]

Config.java[1.10K]

ConfigChangeCallback.java[1.23K]

ConfigData.java[1.97K]

ConfigDef.java[63.19K]

ConfigException.java[1.39K]

ConfigResource.java[3.14K]

ConfigTransformer.java[8.03K]

ConfigTransformerResult.java[2.16K]

ConfigValue.java[3.26K]

LogLevelConfig.java[2.53K]

SaslConfigs.java[12.41K]

SecurityConfig.java[1.29K]

SslClientAuth.java[1.57K]

SslConfigs.java[10.87K]

TopicConfig.java[13.49K]

errors[126.85K]

ApiException.java[1.55K]

AuthenticationException.java[2.02K]

AuthorizationException.java[1.07K]

BrokerNotAvailableException.java[1.13K]

ClusterAuthorizationException.java[1.15K]

ConcurrentTransactionsException.java[1.04K]

ControllerMovedException.java[1.13K]

CoordinatorLoadInProgressException.java[1.63K]

CoordinatorNotAvailableException.java[1.69K]

CorruptRecordException.java[1.53K]

DelegationTokenAuthorizationException.java[1.17K]

DelegationTokenDisabledException.java[1.15K]

DelegationTokenExpiredException.java[1.15K]

DelegationTokenNotFoundException.java[1.15K]

DelegationTokenOwnerMismatchException.java[1.16K]

DisconnectException.java[1.40K]

DuplicateSequenceException.java[0.97K]

ElectionNotNeededException.java[1.09K]

EligibleLeadersNotAvailableException.java[1.12K]

FencedInstanceIdException.java[1.13K]

FencedLeaderEpochException.java[1.41K]

FetchSessionIdNotFoundException.java[1.09K]

GroupAuthorizationException.java[1.58K]

GroupIdNotFoundException.java[0.96K]

GroupMaxSizeReachedException.java[1.15K]

GroupNotEmptyException.java[0.96K]

GroupSubscribedToTopicException.java[0.98K]

IllegalGenerationException.java[1.28K]

IllegalSaslStateException.java[1.34K]

InconsistentGroupProtocolException.java[1.15K]

InterruptException.java[1.47K]

InvalidCommitOffsetSizeException.java[1.15K]

InvalidConfigurationException.java[1.14K]

InvalidFetchSessionEpochException.java[1.10K]

InvalidFetchSizeException.java[1.13K]

InvalidGroupIdException.java[1.12K]

InvalidMetadataException.java[1.36K]

InvalidOffsetException.java[1.30K]

InvalidPartitionsException.java[1.13K]

InvalidPidMappingException.java[0.97K]

InvalidPrincipalTypeException.java[1.14K]

InvalidReplicaAssignmentException.java[1.15K]

InvalidReplicationFactorException.java[1.15K]

InvalidRequestException.java[1.32K]

InvalidRequiredAcksException.java[1.02K]

InvalidSessionTimeoutException.java[1.14K]

InvalidTimestampException.java[1.18K]

InvalidTopicException.java[2.02K]

InvalidTxnStateException.java[0.96K]

InvalidTxnTimeoutException.java[1.31K]

KafkaStorageException.java[2.00K]

LeaderNotAvailableException.java[1.31K]

ListenerNotFoundException.java[1.55K]

LogDirNotFoundException.java[1.29K]

MemberIdRequiredException.java[1.13K]

NetworkException.java[1.43K]

NoReassignmentInProgressException.java[1.18K]

NotControllerException.java[1.13K]

NotCoordinatorException.java[1.47K]

NotEnoughReplicasAfterAppendException.java[1.29K]

NotEnoughReplicasException.java[1.37K]

NotLeaderForPartitionException.java[1.37K]

OffsetMetadataTooLarge.java[1.37K]

OffsetNotAvailableException.java[1.22K]

OffsetOutOfRangeException.java[1.31K]

OperationNotAttemptedException.java[1.19K]

OutOfOrderSequenceException.java[1.47K]

PolicyViolationException.java[1.18K]

PreferredLeaderNotAvailableException.java[1.12K]

ProducerFencedException.java[1.38K]

ReassignmentInProgressException.java[1.17K]

RebalanceInProgressException.java[1.29K]

RecordBatchTooLargeException.java[1.36K]

RecordTooLargeException.java[1.77K]

ReplicaNotAvailableException.java[1.22K]

RetriableException.java[1.32K]

SaslAuthenticationException.java[1.98K]

SecurityDisabledException.java[1.20K]

SerializationException.java[1.53K]

SslAuthenticationException.java[1.69K]

StaleBrokerEpochException.java[1.13K]

TimeoutException.java[1.28K]

TopicAuthorizationException.java[1.75K]

TopicDeletionDisabledException.java[1.08K]

TopicExistsException.java[1.11K]

TransactionalIdAuthorizationException.java[1.00K]

TransactionCoordinatorFencedException.java[1.16K]

UnknownLeaderEpochException.java[1.41K]

UnknownMemberIdException.java[1.27K]

UnknownProducerIdException.java[1.41K]

UnknownServerException.java[1.39K]

UnknownTopicOrPartitionException.java[1.59K]

UnsupportedByAuthenticationException.java[1.23K]

UnsupportedCompressionTypeException.java[1.25K]

UnsupportedForMessageFormatException.java[1.37K]

UnsupportedSaslMechanismException.java[1.28K]

UnsupportedVersionException.java[1.96K]

WakeupException.java[1.32K]

header[11.93K]

internals[8.16K]

RecordHeader.java[2.42K]

RecordHeaders.java[5.74K]

Header.java[0.89K]

Headers.java[2.87K]

internals[24.89K]

ClusterResourceListeners.java[2.25K]

FatalExitError.java[1.64K]

KafkaFutureImpl.java[10.54K]

PartitionStates.java[6.80K]

Topic.java[3.65K]

memory[15.95K]

GarbageCollectedMemoryPool.java[7.45K]

MemoryPool.java[2.97K]

SimpleMemoryPool.java[5.53K]

metrics[121.89K]

stats[52.84K]

Avg.java[1.52K]

Count.java[1.22K]

CumulativeCount.java[1.43K]

CumulativeSum.java[1.58K]

Frequencies.java[8.42K]

Frequency.java[1.79K]

Histogram.java[7.21K]

Max.java[1.59K]

Meter.java[3.11K]

Min.java[1.57K]

Percentile.java[1.25K]

Percentiles.java[4.54K]

Rate.java[4.73K]

SampledStat.java[4.68K]

SimpleRate.java[1.50K]

Sum.java[1.16K]

Total.java[1.17K]

Value.java[1.26K]

WindowedCount.java[1.52K]

WindowedSum.java[1.58K]

CompoundStat.java[1.56K]

Gauge.java[1.21K]

JmxReporter.java[9.06K]

KafkaMetric.java[3.30K]

Measurable.java[1.25K]

MeasurableStat.java[1.25K]

MetricConfig.java[2.77K]

Metrics.java[28.37K]

MetricsReporter.java[1.84K]

MetricValueProvider.java[1.20K]

Quota.java[2.14K]

QuotaViolationException.java[1.78K]

Sensor.java[12.11K]

Stat.java[1.24K]

network[220.33K]

Authenticator.java[7.08K]

ByteBufferSend.java[2.10K]

ChannelBuilder.java[1.68K]

ChannelBuilders.java[10.54K]

ChannelState.java[4.87K]

DelayedResponseAuthenticationException.java[1.12K]

InvalidReceiveException.java[1.12K]

KafkaChannel.java[26.82K]

ListenerName.java[2.50K]

ListenerReconfigurable.java[1.23K]

Mode.java[0.91K]

NetworkReceive.java[5.10K]

NetworkSend.java[1.35K]

PlaintextChannelBuilder.java[4.16K]

PlaintextTransportLayer.java[6.92K]

ReauthenticationContext.java[4.04K]

Receive.java[1.79K]

SaslChannelBuilder.java[16.20K]

Selectable.java[3.53K]

Selector.java[62.08K]

Send.java[1.59K]

SslChannelBuilder.java[9.07K]

SslTransportLayer.java[38.93K]

TransportLayer.java[4.24K]

TransportLayers.java[1.40K]

protocol[154.62K]

types[82.66K]

ArrayOf.java[3.84K]

BoundField.java[1.22K]

CompactArrayOf.java[4.24K]

Field.java[6.20K]

RawTaggedField.java[1.57K]

RawTaggedFieldWriter.java[2.90K]

Schema.java[7.64K]

SchemaException.java[1.15K]

Struct.java[16.08K]

TaggedFields.java[6.61K]

Type.java[31.20K]

ApiKeys.java[20.58K]

ApiMessage.java[1.03K]

ByteBufferAccessor.java[2.09K]

CommonFields.java[5.14K]

Errors.java[25.39K]

Message.java[3.85K]

MessageUtil.java[1.77K]

ObjectSerializationCache.java[1.93K]

Protocol.java[7.15K]

Readable.java[1.83K]

Writable.java[1.21K]

record[325.24K]

AbstractLegacyRecordBatch.java[20.04K]

AbstractRecordBatch.java[1.19K]

AbstractRecords.java[6.18K]

BaseRecords.java[1.30K]

BufferSupplier.java[4.23K]

ByteBufferLogInputStream.java[3.63K]

CompressionRatioEstimator.java[4.77K]

CompressionType.java[9.58K]

ControlRecordType.java[3.90K]

ConvertedRecords.java[1.30K]

DefaultRecord.java[24.21K]

DefaultRecordBatch.java[28.36K]

DefaultRecordsSend.java[1.44K]

EndTransactionMarker.java[5.01K]

FileLogInputStream.java[9.16K]

FileRecords.java[21.09K]

KafkaLZ4BlockInputStream.java[10.18K]

KafkaLZ4BlockOutputStream.java[14.17K]

LazyDownConversionRecords.java[8.60K]

LazyDownConversionRecordsSend.java[5.22K]

LegacyRecord.java[22.22K]

LogInputStream.java[1.98K]

MemoryRecords.java[32.92K]

MemoryRecordsBuilder.java[34.31K]

MultiRecordsSend.java[4.72K]

MutableRecordBatch.java[2.80K]

PartialDefaultRecord.java[2.84K]

Record.java[4.36K]

RecordBatch.java[8.22K]

RecordBatchIterator.java[1.47K]

RecordConversionStats.java[2.69K]

Records.java[5.74K]

RecordsSend.java[3.42K]

RecordsUtil.java[6.83K]

RecordVersion.java[1.95K]

SimpleRecord.java[3.71K]

TimestampType.java[1.50K]

replica[13.66K]

ClientMetadata.java[3.71K]

PartitionView.java[2.31K]

RackAwareReplicaSelector.java[2.32K]

ReplicaSelector.java[1.76K]

ReplicaView.java[3.56K]

requests[648.93K]

AbstractControlRequest.java[1.87K]

AbstractRequest.java[9.92K]

AbstractRequestResponse.java[0.87K]

AbstractResponse.java[8.74K]

AddOffsetsToTxnRequest.java[5.25K]

AddOffsetsToTxnResponse.java[3.47K]

AddPartitionsToTxnRequest.java[7.36K]

AddPartitionsToTxnResponse.java[5.91K]

AlterConfigsRequest.java[8.76K]

AlterConfigsResponse.java[5.09K]

AlterPartitionReassignmentsRequest.java[4.53K]

AlterPartitionReassignmentsResponse.java[3.13K]

AlterReplicaLogDirsRequest.java[7.31K]

AlterReplicaLogDirsResponse.java[5.86K]

ApiError.java[3.41K]

ApiVersionsRequest.java[5.17K]

ApiVersionsResponse.java[5.67K]

ControlledShutdownRequest.java[3.00K]

ControlledShutdownResponse.java[3.14K]

CreateAclsRequest.java[7.57K]

CreateAclsResponse.java[4.68K]

CreateDelegationTokenRequest.java[2.82K]

CreateDelegationTokenResponse.java[3.56K]

CreatePartitionsRequest.java[10.54K]

CreatePartitionsResponse.java[4.53K]

CreateTopicsRequest.java[4.50K]

CreateTopicsResponse.java[2.84K]

DeleteAclsRequest.java[7.21K]

DeleteAclsResponse.java[10.19K]

DeleteGroupsRequest.java[3.19K]

DeleteGroupsResponse.java[3.42K]

DeleteRecordsRequest.java[7.72K]

DeleteRecordsResponse.java[7.44K]

DeleteTopicsRequest.java[3.13K]

DeleteTopicsResponse.java[2.67K]

DescribeAclsRequest.java[5.69K]

DescribeAclsResponse.java[8.01K]

DescribeConfigsRequest.java[8.48K]

DescribeConfigsResponse.java[15.79K]

DescribeDelegationTokenRequest.java[3.14K]

DescribeDelegationTokenResponse.java[4.61K]

DescribeGroupsRequest.java[2.95K]

DescribeGroupsResponse.java[5.66K]

DescribeLogDirsRequest.java[6.52K]

DescribeLogDirsResponse.java[10.42K]

ElectLeadersRequest.java[5.32K]

ElectLeadersResponse.java[4.43K]

EndTxnRequest.java[5.26K]

EndTxnResponse.java[3.31K]

EpochEndOffset.java[2.66K]

ExpireDelegationTokenRequest.java[3.02K]

ExpireDelegationTokenResponse.java[2.40K]

FetchMetadata.java[4.50K]

FetchRequest.java[24.35K]

FetchResponse.java[29.01K]

FindCoordinatorRequest.java[3.95K]

FindCoordinatorResponse.java[3.19K]

HeartbeatRequest.java[3.00K]

HeartbeatResponse.java[2.37K]

IncrementalAlterConfigsRequest.java[3.60K]

IncrementalAlterConfigsResponse.java[3.99K]

InitProducerIdRequest.java[3.27K]

InitProducerIdResponse.java[2.49K]

IsolationLevel.java[1.35K]

JoinGroupRequest.java[6.54K]

JoinGroupResponse.java[2.75K]

LeaderAndIsrRequest.java[7.47K]

LeaderAndIsrResponse.java[2.70K]

LeaveGroupRequest.java[4.96K]

LeaveGroupResponse.java[5.43K]

ListGroupsRequest.java[2.94K]

ListGroupsResponse.java[2.14K]

ListOffsetRequest.java[14.63K]

ListOffsetResponse.java[12.50K]

ListPartitionReassignmentsRequest.java[4.38K]

ListPartitionReassignmentsResponse.java[2.55K]

MetadataRequest.java[7.07K]

MetadataResponse.java[19.17K]

OffsetCommitRequest.java[6.26K]

OffsetCommitResponse.java[4.68K]

OffsetDeleteRequest.java[2.81K]

OffsetDeleteResponse.java[3.35K]

OffsetFetchRequest.java[6.16K]

OffsetFetchResponse.java[9.48K]

OffsetsForLeaderEpochRequest.java[11.04K]

OffsetsForLeaderEpochResponse.java[8.76K]

ProduceRequest.java[19.73K]

ProduceResponse.java[18.91K]

RenewDelegationTokenRequest.java[2.91K]

RenewDelegationTokenResponse.java[2.38K]

RequestAndSize.java[1.05K]

RequestContext.java[4.77K]

RequestHeader.java[4.15K]

RequestUtils.java[6.43K]

ResponseHeader.java[2.26K]

SaslAuthenticateRequest.java[3.60K]

SaslAuthenticateResponse.java[2.49K]

SaslHandshakeRequest.java[3.47K]

SaslHandshakeResponse.java[2.46K]

StopReplicaRequest.java[6.93K]

StopReplicaResponse.java[2.67K]

SyncGroupRequest.java[4.09K]

SyncGroupResponse.java[2.33K]

TransactionResult.java[1.15K]

TxnOffsetCommitRequest.java[7.91K]

TxnOffsetCommitResponse.java[4.40K]

UpdateMetadataRequest.java[10.04K]

UpdateMetadataResponse.java[1.92K]

WriteTxnMarkersRequest.java[10.50K]

WriteTxnMarkersResponse.java[7.43K]

resource[23.70K]

PatternType.java[4.05K]

Resource.java[2.93K]

ResourceFilter.java[3.56K]

ResourcePattern.java[3.94K]

ResourcePatternFilter.java[6.10K]

ResourceType.java[3.12K]

security[504.39K]

auth[138.01K]

authenticator[108.34K]

AbstractLogin.java[4.43K]

CredentialCache.java[2.51K]

DefaultKafkaPrincipalBuilder.java[8.19K]

DefaultLogin.java[1.01K]

LoginManager.java[10.87K]

SaslClientAuthenticator.java[32.44K]

SaslClientCallbackHandler.java[5.41K]

SaslInternalConfigs.java[2.09K]

SaslServerAuthenticator.java[38.19K]

SaslServerCallbackHandler.java[3.20K]

AuthenticateCallbackHandler.java[3.11K]

AuthenticationContext.java[1.45K]

DefaultPrincipalBuilder.java[1.68K]

KafkaPrincipal.java[4.43K]

KafkaPrincipalBuilder.java[1.67K]

Login.java[2.64K]

PlaintextAuthenticationContext.java[1.48K]

PrincipalBuilder.java[1.77K]

SaslAuthenticationContext.java[1.78K]

SaslExtensions.java[1.98K]

SaslExtensionsCallback.java[1.88K]

SecurityProtocol.java[2.68K]

SecurityProviderCreator.java[1.47K]

SslAuthenticationContext.java[1.65K]

kerberos[42.22K]

BadFormatString.java[1.05K]

KerberosClientCallbackHandler.java[3.58K]

KerberosError.java[3.91K]

KerberosLogin.java[17.76K]

KerberosName.java[3.30K]

KerberosRule.java[7.36K]

KerberosShortNamer.java[4.29K]

NoMatchingRule.java[0.97K]

oauthbearer[175.53K]

internals[136.63K]

expiring[31.07K]

ExpiringCredential.java[2.65K]

ExpiringCredentialRefreshConfig.java[5.64K]

ExpiringCredentialRefreshingLogin.java[22.78K]

unsecured[61.80K]

OAuthBearerConfigException.java[1.34K]

OAuthBearerIllegalTokenException.java[2.00K]

OAuthBearerScopeUtils.java[3.16K]

OAuthBearerUnsecuredJws.java[14.56K]

OAuthBearerUnsecuredLoginCallbackHandler.java[15.95K]

OAuthBearerUnsecuredValidatorCallbackHandler.java[10.80K]

OAuthBearerValidationResult.java[4.45K]

OAuthBearerValidationUtils.java[9.54K]

OAuthBearerClientInitialResponse.java[7.87K]

OAuthBearerRefreshingLogin.java[6.53K]

OAuthBearerSaslClient.java[8.35K]

OAuthBearerSaslClientCallbackHandler.java[6.78K]

OAuthBearerSaslClientProvider.java[1.61K]

OAuthBearerSaslServer.java[11.01K]

OAuthBearerSaslServerProvider.java[1.61K]

OAuthBearerExtensionsValidatorCallback.java[5.02K]

OAuthBearerLoginModule.java[19.24K]

OAuthBearerToken.java[4.46K]

OAuthBearerTokenCallback.java[4.34K]

OAuthBearerValidatorCallback.java[5.85K]

plain[16.61K]

internals[12.37K]

PlainSaslServer.java[7.79K]

PlainSaslServerProvider.java[1.50K]

PlainServerCallbackHandler.java[3.08K]

PlainAuthenticateCallback.java[2.21K]

PlainLoginModule.java[2.03K]

scram[63.53K]

internals[55.82K]

ScramCredentialUtils.java[3.67K]

ScramExtensions.java[1.52K]

ScramFormatter.java[7.56K]

ScramMechanism.java[2.42K]

ScramMessages.java[10.80K]

ScramSaslClient.java[10.65K]

ScramSaslClientProvider.java[1.55K]

ScramSaslServer.java[12.62K]

ScramSaslServerProvider.java[1.55K]

ScramServerCallbackHandler.java[3.48K]

ScramCredential.java[2.12K]

ScramCredentialCallback.java[1.37K]

ScramExtensionsCallback.java[1.66K]

ScramLoginModule.java[2.56K]

ssl[38.19K]

SslEngineBuilder.java[13.15K]

SslFactory.java[16.93K]

SslPrincipalMapper.java[8.11K]

token[12.70K]

delegation[12.70K]

internals[6.34K]

DelegationTokenCache.java[4.90K]

DelegationTokenCredentialCallback.java[1.44K]

DelegationToken.java[2.31K]

TokenInformation.java[4.06K]

JaasConfig.java[5.14K]

JaasContext.java[9.05K]

JaasUtils.java[3.41K]

serialization[48.51K]

ByteArrayDeserializer.java[1.00K]

ByteArraySerializer.java[0.99K]

ByteBufferDeserializer.java[1.08K]

ByteBufferSerializer.java[1.39K]

BytesDeserializer.java[1.08K]

BytesSerializer.java[1.07K]

Deserializer.java[2.77K]

DoubleDeserializer.java[1.38K]

DoubleSerializer.java[1.36K]

ExtendedDeserializer.java[3.15K]

ExtendedSerializer.java[2.90K]

FloatDeserializer.java[1.38K]

FloatSerializer.java[1.23K]

IntegerDeserializer.java[1.35K]

IntegerSerializer.java[1.17K]

LongDeserializer.java[1.34K]

LongSerializer.java[1.29K]

Serde.java[1.84K]

Serdes.java[7.20K]

Serializer.java[2.39K]

ShortDeserializer.java[1.35K]

ShortSerializer.java[1.10K]

StringDeserializer.java[2.11K]

StringSerializer.java[2.08K]

UUIDDeserializer.java[2.36K]

UUIDSerializer.java[2.17K]

utils[260.73K]

AbstractIterator.java[2.43K]

AppInfoParser.java[5.27K]

ByteBufferInputStream.java[1.48K]

ByteBufferOutputStream.java[4.97K]

Bytes.java[6.42K]

ByteUtils.java[13.93K]

Checksums.java[2.62K]

CircularIterator.java[1.53K]

CloseableIterator.java[1.73K]

CollectionUtils.java[2.87K]

CopyOnWriteMap.java[3.69K]

Crc32.java[31.53K]

Crc32C.java[3.89K]

Exit.java[2.47K]

FixedOrderMap.java[2.13K]

FlattenedIterator.java[1.73K]

ImplicitLinkedHashCollection.java[21.01K]

ImplicitLinkedHashMultiCollection.java[5.01K]

Java.java[2.34K]

KafkaThread.java[1.93K]

LogContext.java[24.43K]

LoggingSignalHandler.java[4.59K]

MappedByteBuffers.java[5.51K]

MappedIterator.java[1.52K]

OperatingSystem.java[1.14K]

PrimitiveRef.java[1.21K]

PureJavaCrc32C.java[32.62K]

Sanitizer.java[3.68K]

Scheduler.java[1.88K]

SecurityUtils.java[4.82K]

Shell.java[9.80K]

SystemScheduler.java[1.52K]

SystemTime.java[1.87K]

Time.java[3.24K]

Timer.java[6.91K]

Utils.java[37.00K]

Cluster.java[14.85K]

ClusterResource.java[2.12K]

ClusterResourceListener.java[4.13K]

Configurable.java[1.11K]

ConsumerGroupState.java[1.75K]

ElectionType.java[1.69K]

Endpoint.java[2.99K]

InvalidRecordException.java[1.15K]

KafkaException.java[1.27K]

KafkaFuture.java[7.86K]

Metric.java[1.35K]

MetricName.java[4.71K]

MetricNameTemplate.java[4.34K]

Node.java[3.62K]

PartitionInfo.java[3.71K]

Reconfigurable.java[2.17K]

TopicPartition.java[2.12K]

TopicPartitionInfo.java[3.57K]

TopicPartitionReplica.java[2.37K]

server[39.32K]

authorizer[21.88K]

AclCreateResult.java[1.53K]

AclDeleteResult.java[3.30K]

Action.java[4.58K]

AuthorizableRequestContext.java[2.21K]

AuthorizationResult.java[0.97K]

Authorizer.java[7.53K]

AuthorizerServerInfo.java[1.76K]

policy[9.16K]

AlterConfigPolicy.java[3.51K]

CreateTopicPolicy.java[5.65K]

quota[8.28K]

ClientQuotaCallback.java[5.20K]

ClientQuotaEntity.java[2.12K]

ClientQuotaType.java[0.97K]

resources[220.54K]

common[219.71K]

message[219.71K]

AddOffsetsToTxnRequest.json[1.56K]

AddOffsetsToTxnResponse.json[1.37K]

AddPartitionsToTxnRequest.json[1.86K]

AddPartitionsToTxnResponse.json[1.93K]

AlterConfigsRequest.json[1.91K]

AlterConfigsResponse.json[1.88K]

AlterPartitionReassignmentsRequest.json[1.83K]

AlterPartitionReassignmentsResponse.json[2.35K]

AlterReplicaLogDirsRequest.json[1.65K]

AlterReplicaLogDirsResponse.json[1.93K]

ApiVersionsRequest.json[1.31K]

ApiVersionsResponse.json[2.32K]

ControlledShutdownRequest.json[1.48K]

ControlledShutdownResponse.json[1.52K]

CreateAclsRequest.json[1.95K]

CreateAclsResponse.json[1.67K]

CreateDelegationTokenRequest.json[1.61K]

CreateDelegationTokenResponse.json[2.21K]

CreatePartitionsRequest.json[1.99K]

CreatePartitionsResponse.json[1.82K]

CreateTopicsRequest.json[3.21K]

CreateTopicsResponse.json[3.48K]

DeleteAclsRequest.json[2.03K]

DeleteAclsResponse.json[3.01K]

DeleteGroupsRequest.json[1.14K]

DeleteGroupsResponse.json[1.69K]

DeleteRecordsRequest.json[1.77K]

DeleteRecordsResponse.json[2.08K]

DeleteTopicsRequest.json[1.31K]

DeleteTopicsResponse.json[1.84K]

DescribeAclsRequest.json[1.92K]

DescribeAclsResponse.json[2.59K]

DescribeConfigsRequest.json[1.73K]

DescribeConfigsResponse.json[3.68K]

DescribeDelegationTokenRequest.json[1.43K]

DescribeDelegationTokenResponse.json[2.74K]

DescribeGroupsRequest.json[1.46K]

DescribeGroupsResponse.json[3.85K]

DescribeLogDirsRequest.json[1.41K]

DescribeLogDirsResponse.json[2.70K]

ElectLeadersRequest.json[1.92K]

ElectLeadersResponse.json[2.29K]

EndTxnRequest.json[1.50K]

EndTxnResponse.json[1.35K]

ExpireDelegationTokenRequest.json[1.22K]

ExpireDelegationTokenResponse.json[1.51K]

FetchRequest.json[5.25K]

FetchResponse.json[4.23K]

FindCoordinatorRequest.json[1.30K]

FindCoordinatorResponse.json[1.95K]

HeartbeatRequest.json[1.67K]

HeartbeatResponse.json[1.60K]

IncrementalAlterConfigsRequest.json[2.10K]

IncrementalAlterConfigsResponse.json[1.84K]

InitProducerIdRequest.json[1.45K]

InitProducerIdResponse.json[1.71K]

JoinGroupRequest.json[2.88K]

JoinGroupResponse.json[2.72K]

LeaderAndIsrRequest.json[4.35K]

LeaderAndIsrResponse.json[1.71K]

LeaveGroupRequest.json[1.82K]

LeaveGroupResponse.json[2.13K]

ListGroupsRequest.json[1.01K]

ListGroupsResponse.json[1.83K]

ListOffsetRequest.json[2.92K]

ListOffsetResponse.json[2.78K]

ListPartitionReassignmentsRequest.json[1.58K]

ListPartitionReassignmentsResponse.json[2.42K]

MetadataRequest.json[2.27K]

MetadataResponse.json[5.00K]

OffsetCommitRequest.json[3.47K]

OffsetCommitResponse.json[2.28K]

OffsetDeleteRequest.json[1.57K]

OffsetDeleteResponse.json[2.00K]

OffsetFetchRequest.json[2.03K]

OffsetFetchResponse.json[2.72K]

OffsetForLeaderEpochRequest.json[2.56K]

OffsetForLeaderEpochResponse.json[2.24K]

ProduceRequest.json[2.77K]

ProduceResponse.json[3.78K]

README.md[11.43K]

RenewDelegationTokenRequest.json[1.21K]

RenewDelegationTokenResponse.json[1.51K]

RequestHeader.json[2.00K]

ResponseHeader.json[1.06K]

SaslAuthenticateRequest.json[1.12K]

SaslAuthenticateResponse.json[1.59K]

SaslHandshakeRequest.json[1.08K]

SaslHandshakeResponse.json[1.21K]

StopReplicaRequest.json[2.25K]

StopReplicaResponse.json[1.64K]

SyncGroupRequest.json[2.06K]

SyncGroupResponse.json[1.70K]

TxnOffsetCommitRequest.json[2.65K]

TxnOffsetCommitResponse.json[1.97K]

UpdateMetadataRequest.json[5.03K]

UpdateMetadataResponse.json[1.10K]

WriteTxnMarkersRequest.json[2.16K]

WriteTxnMarkersResponse.json[1.92K]

META-INF[0.83K]

services[0.83K]

org.apache.kafka.common.config.provider.ConfigProvider[0.83K]

test[165.15K]

java[165.15K]

org[165.15K]

apache[165.15K]

kafka[165.15K]

clients[165.15K]

admin[165.15K]

internals[4.23K]

AdminMetadataManagerTest.java[4.23K]

AdminClientUnitTestEnv.java[4.93K]

ConfigTest.java[3.06K]

DeleteConsumerGroupOffsetsResultTest.java[5.20K]

KafkaAdminClientTest.java[122.50K]

MemberDescriptionTest.java[4.98K]

MockAdminClient.java[20.25K]

.gitignore[0.01K]

.gitignore[0.56K]

.travis.yml[1.71K]

build.gradle[58.67K]

bzip2-0.9.1.jar[48.65K]

7.笔记[648.26K]

image[385.53K]

image-20200916093856262.png[96.05K]

image-20200916093908261.png[108.66K]

image-20200916093919754.png[115.45K]

image-20200916093933994.png[65.36K]

Kafka第二天笔记.md[8.74K]

Kafka第二天总结.xmind[131.36K]

Kafka第一天.xmind[103.72K]

Kafka第一天笔记.md[18.91K]

8.作业[158.51K]

第1章Kafka入门作业_v1.1.docx[80.88K]

第2章Kafka高级作业_v1.1.docx[77.63K]