path	# lines of code
cmake_modules/FindClangTools.cmake	93
proto/PulsarApi.proto	901
dependencies.yaml	8
include/pulsar/KeyValue.h	24
include/pulsar/TableViewConfiguration.h	11
include/pulsar/DeprecatedException.h	14
include/pulsar/Reader.h	41
include/pulsar/MessageRoutingPolicy.h	23
include/pulsar/ConsumerCryptoFailureAction.h	11
include/pulsar/Client.h	84
include/pulsar/ConsoleLoggerFactory.h	13
include/pulsar/ProducerInterceptor.h	19
include/pulsar/TypedMessageBuilder.h	47
include/pulsar/ConsumerEventListener.h	13
include/pulsar/BrokerConsumerStats.h	39
include/pulsar/BatchReceivePolicy.h	18
include/pulsar/ProducerCryptoFailureAction.h	10
include/pulsar/MessageBuilder.h	42
include/pulsar/EncryptionKeyInfo.h	26
include/pulsar/RegexSubscriptionMode.h	11
include/pulsar/Result.h	60
include/pulsar/ConsumerType.h	12
include/pulsar/Message.h	75
include/pulsar/MessageBatch.h	21
include/pulsar/CryptoKeyReader.h	32
include/pulsar/Schema.h	55
include/pulsar/TableView.h	32
include/pulsar/ReaderConfiguration.h	63
include/pulsar/TypedMessage.h	21
include/pulsar/Consumer.h	84
include/pulsar/ConsumerConfiguration.h	128
include/pulsar/ConsumerInterceptor.h	21
include/pulsar/defines.h	16
include/pulsar/FileLoggerFactory.h	13
include/pulsar/DeadLetterPolicy.h	21
include/pulsar/InitialPosition.h	10
include/pulsar/ProtobufNativeSchema.h	6
include/pulsar/DeadLetterPolicyBuilder.h	19
include/pulsar/Producer.h	38
include/pulsar/Authentication.h	162
include/pulsar/TopicMetadata.h	11
include/pulsar/MessageId.h	56
include/pulsar/Logger.h	24
include/pulsar/MessageIdBuilder.h	22
include/pulsar/CompressionType.h	13
include/pulsar/c/string_list.h	14
include/pulsar/c/reader.h	28
include/pulsar/c/client.h	89
include/pulsar/c/version.h	2
include/pulsar/c/messages.h	14
include/pulsar/c/message_router.h	13
include/pulsar/c/table_view.h	29
include/pulsar/c/result.h	58
include/pulsar/c/message.h	46
include/pulsar/c/consumer.h	71
include/pulsar/c/message_id.h	17
include/pulsar/c/consumer_configuration.h	147
include/pulsar/c/string_map.h	16
include/pulsar/c/table_view_configuration.h	19
include/pulsar/c/producer.h	29
include/pulsar/c/authentication.h	22
include/pulsar/c/producer_configuration.h	143
include/pulsar/c/client_configuration.h	77
include/pulsar/c/reader_configuration.h	41
include/pulsar/ProducerConfiguration.h	109
include/pulsar/KeySharedPolicy.h	32
include/pulsar/ClientConfiguration.h	63
eclipse-formatter.xml	167
win-examples/example.cc	7
lib/UnAckedMessageTrackerEnabled.cc	136
lib/FileLoggerFactory.cc	8
lib/MessageIdUtil.h	21
lib/Semaphore.h	22
lib/EncryptionKeyInfoImpl.h	21
lib/LogUtils.h	63
lib/ProducerInterceptors.cc	56
lib/ConsoleLoggerFactoryImpl.h	12
lib/EncryptionKeyInfoImpl.cc	9
lib/UtilAllocator.h	49
lib/TopicMetadataImpl.cc	5
lib/HTTPLookupService.cc	415
lib/Utils.h	40
lib/ReaderImpl.cc	132
lib/Synchronized.h	19
lib/KeyValueImpl.cc	46
lib/BitSet.h	152
lib/ProtobufNativeSchema.cc	34
lib/HandlerBase.h	77
lib/RetryableOperationCache.h	78
lib/DeprecatedException.cc	6
lib/UnAckedMessageTrackerEnabled.h	45
lib/Int64SerDes.h	18
lib/ServiceNameResolver.h	31
lib/CompressionCodecZstd.cc	39
lib/TableViewImpl.h	44
lib/KeySharedPolicy.cc	53
lib/ConnectionPool.cc	78
lib/Future.h	100
lib/RoundRobinMessageRouter.cc	51
lib/ClientImpl.h	123
lib/ServiceURI.cc	74
lib/SchemaUtils.h	25
lib/Schema.cc	156
lib/AckGroupingTrackerEnabled.h	57
lib/RoundRobinMessageRouter.h	25
lib/Commands.cc	797
lib/LookupService.h	40
lib/PatternMultiTopicsConsumerImpl.cc	177
lib/MultiTopicsConsumerImpl.cc	948
lib/CompressionCodecSnappy.cc	40
lib/NamedEntity.h	6
lib/CryptoKeyReader.cc	49
lib/MultiTopicsBrokerConsumerStatsImpl.cc	119
lib/TimeUtils.cc	9
lib/BoostHash.h	17
lib/DeadLetterPolicyBuilder.cc	27
lib/HTTPLookupService.h	52
lib/auth/AuthOauth2.cc	364
lib/auth/AuthBasic.h	21
lib/auth/InitialAuthData.h	14
lib/auth/AuthTls.h	17
lib/auth/AuthToken.h	18
lib/auth/AuthOauth2.h	68
lib/auth/AuthAthenz.cc	60
lib/auth/AuthTls.cc	30
lib/auth/AuthToken.cc	70
lib/auth/AuthBasic.cc	87
lib/auth/AuthAthenz.h	20
lib/auth/athenz/ZTSClient.cc	332
lib/auth/athenz/ZTSClient.h	44
lib/MessageBatch.cc	31
lib/TableViewImpl.cc	131
lib/BatchMessageContainer.h	24
lib/JavaStringHash.h	14
lib/CompressionCodecLZ4.h	11
lib/GetLastMessageIdResponse.h	35
lib/ConnectionPool.h	42
lib/Consumer.cc	236
lib/BatchReceivePolicy.cc	29
lib/MessagesImpl.cc	31
lib/ConsumerImpl.cc	1477
lib/BatchMessageContainer.cc	46
lib/ProducerInterceptors.h	27
lib/BatchMessageAcker.h	52
lib/Url.cc	69
lib/NamespaceName.cc	75
lib/OpSendMsg.h	48
lib/MessageRouterBase.h	17
lib/Murmur3_32Hash.h	21
lib/NegativeAcksTracker.h	40
lib/MessageImpl.cc	93
lib/Reader.cc	95
lib/MultiTopicsConsumerImpl.h	150
lib/Result.cc	107
lib/MessageIdBuilder.cc	47
lib/ProtoApiEnums.h	114
lib/lz4/lz4.h	85
lib/lz4/lz4.cc	1146
lib/ChunkMessageIdImpl.h	21
lib/MessageIdImpl.h	52
lib/MessageAndCallbackBatch.cc	44
lib/MultiTopicsBrokerConsumerStatsImpl.h	34
lib/TopicMetadataImpl.h	13
lib/Commands.h	112
lib/AckGroupingTrackerEnabled.cc	135
lib/SynchronizedHashMap.h	102
lib/BatchMessageKeyBasedContainer.cc	94
lib/MapCache.h	84
lib/MessageRouterBase.cc	20
lib/TimeUtils.h	34
lib/Authentication.cc	173
lib/ConsumerImplBase.h	77
lib/CompressionCodecZLib.cc	56
lib/AckGroupingTrackerDisabled.cc	18
lib/ProducerImpl.cc	800
lib/Client.cc	143
lib/ConsumerInterceptors.cc	65
lib/ConsumerConfiguration.cc	230
lib/EncryptionKeyInfo.cc	10
lib/ClientConfigurationImpl.h	30
lib/Murmur3_32Hash.cc	81
lib/DeadLetterPolicyImpl.h	10
lib/AckGroupingTracker.cc	87
lib/FileLoggerFactoryImpl.h	18
lib/UnboundedBlockingQueue.h	116
lib/BatchMessageContainerBase.cc	82
lib/Backoff.h	24
lib/RetryableLookupService.h	64
lib/PulsarScheme.h	55
lib/ObjectPool.h	166
lib/BinaryProtoLookupService.cc	186
lib/Semaphore.cc	43
lib/ClientConnection.cc	1483
lib/CompressionCodec.h	36
lib/BoostHash.cc	7
lib/PendingFailures.h	19
lib/BatchMessageKeyBasedContainer.h	27
lib/ProducerImpl.h	131
lib/Url.h	28
lib/SinglePartitionMessageRouter.h	21
lib/NamedEntity.cc	20
lib/LookupDataResult.h	46
lib/ProducerImplBase.h	29
lib/JavaStringHash.cc	15
lib/KeyValueImpl.h	24
lib/MessageBuilder.cc	123
lib/PeriodicTask.h	29
lib/ConsoleLoggerFactory.cc	8
lib/LogUtils.cc	27
lib/CompressionCodecSnappy.h	9
lib/Backoff.cc	33
lib/Producer.cc	74
lib/MemoryLimitController.cc	46
lib/AckGroupingTrackerDisabled.h	16
lib/ClientConnection.h	272
lib/ProducerConfiguration.cc	205
lib/MessageAndCallbackBatch.h	31
lib/CompressionCodec.cc	34
lib/BrokerConsumerStatsImpl.cc	68
lib/BatchMessageContainerBase.h	74
lib/ServiceUnitId.h	7
lib/ClientConfiguration.cc	130
lib/TopicName.h	60
lib/CompressionCodecZLib.h	11
lib/Latch.cc	19
lib/TableView.cc	64
lib/ExecutorService.cc	109
lib/MessageCrypto.h	62
lib/Message.cc	190
lib/BatchReceivePolicyImpl.h	8
lib/BrokerConsumerStats.cc	36
lib/MessageCrypto.cc	398
lib/ReaderImpl.h	59
lib/SharedBuffer.h	164
lib/MultiResultCallback.h	26
lib/MessagesImpl.h	22
lib/ConsumerImpl.h	247
lib/ClientImpl.cc	648
lib/AckGroupingTracker.h	47
lib/CompressionCodecZstd.h	9
lib/UnAckedMessageTrackerDisabled.h	15
lib/PartitionedProducerImpl.cc	386
lib/BlockingQueue.h	141
lib/TopicName.cc	209
lib/NamespaceName.h	33
lib/ProducerConfigurationImpl.h	35
lib/HandlerBase.cc	129
lib/Latch.h	35
lib/RetryableOperation.h	100
lib/UnAckedMessageTrackerInterface.h	20
lib/ConsumerInterceptors.h	28
lib/SinglePartitionMessageRouter.cc	27
lib/checksum/ChecksumProvider.cc	34
lib/checksum/int_types.h	18
lib/checksum/crc32c_sse42.h	22
lib/checksum/crc32c_arm.h	35
lib/checksum/ChecksumProvider.h	11
lib/checksum/crc32c_sse42.cc	225
lib/checksum/crc32c_arm.cc	132
lib/checksum/crc32c_sw.cc	53
lib/checksum/crc32c_sw.h	5
lib/checksum/gf2.hpp	132
lib/ReaderConfigurationImpl.h	24
lib/KeySharedPolicyImpl.h	10
lib/DeadLetterPolicyImpl.cc	12
lib/PatternMultiTopicsConsumerImpl.h	55
lib/PeriodicTask.cc	39
lib/c/cStringMap.cc	30
lib/c/c_Client.cc	222
lib/c/c_Producer.cc	45
lib/c/c_MessageRouter.cc	5
lib/c/c_ClientConfiguration.cc	132
lib/c/c_structs.h	63
lib/c/c_ReaderConfiguration.cc	71
lib/c/c_ConsumerConfiguration.cc	244
lib/c/c_TableViewConfiguration.cc	22
lib/c/c_ProducerConfiguration.cc	178
lib/c/c_Message.cc	91
lib/c/cStringList.cc	9
lib/c/c_MessageId.cc	48
lib/c/c_Result.cc	3
lib/c/c_Reader.cc	51
lib/c/c_Messages.cc	7
lib/c/c_Authentication.cc	49
lib/c/c_Consumer.cc	152
lib/c/c_TableView.cc	59
lib/ReaderConfiguration.cc	102
lib/ServiceURI.h	17
lib/PartitionedProducerImpl.h	92
lib/MessageImpl.h	54
lib/Hash.h	12
lib/stats/ProducerStatsImpl.h	65
lib/stats/ProducerStatsDisabled.h	11
lib/stats/ConsumerStatsBase.h	16
lib/stats/ProducerStatsBase.h	16
lib/stats/ConsumerStatsImpl.h	53
lib/stats/ConsumerStatsImpl.cc	86
lib/stats/ConsumerStatsDisabled.h	11
lib/stats/ProducerStatsImpl.cc	97
lib/KeyValue.cc	11
lib/MessageId.cc	118
lib/ExecutorService.h	61
lib/CompressionCodecLZ4.cc	26
lib/NegativeAcksTracker.cc	77
lib/TestUtil.h	4
lib/Base64Utils.h	30
lib/BrokerConsumerStatsImpl.h	50
lib/ConsumerConfigurationImpl.h	44
lib/BatchedMessageIdImpl.h	24
lib/MemoryLimitController.h	22
lib/ConsumerImplBase.cc	103
lib/BinaryProtoLookupService.h	56
lib/BrokerConsumerStatsImplBase.h	24
lib/SimpleLogger.h	54
templates/Version.h.in	24
build-support/run_clang_format.py	48
build-support/dep-version.py	3
build-support/download-release-artifacts.py	38
build-support/gen-pulsar-version-macro.py	9
perf/RateLimiter.h	50
perf/PerfConsumer.cc	258
perf/PerfProducer.cc	332
wireshark/pulsarDissector.cc	1030
pkg/rpm/SPECS/pulsar-client.spec	72