li-apache-kafka-clients:li-apache-kafka-clients是Apache Kafka香草客户...
需积分: 12 51 浏览量
2021-05-06
21:53:28
上传
评论
收藏 279KB ZIP 举报
li-apache-kafka-clients:li-apache-kafka-clients是Apache Kafka香草客户端的包装库。 它在开源Apache Kafka中提供了其他功能，例如大消息支持以及对Java生产者和消费者的审核。 （134个子文件） 
gradlew.bat 2KB .gitignore 148B build.gradle 7KB build.gradle 1KB build.gradle 1KB settings.gradle 865B build.gradle 645B build.gradle 405B semantic-build-versioning.gradle 0B gradlew 5KB DistributeTask.groovy 2KB
gradle-wrapper.jar 53KB LiKafkaConsumerIntegrationTest.java 80KB LiKafkaConsumerImpl.java 41KB ConsumerRecordsProcessorTest.java 28KB LiKafkaProducerImpl.java 27KB LiKafkaInstrumentedConsumerImpl.java 27KB ConsumerRecordsProcessor.java 26KB LiKafkaInstrumentedProducerImpl.java 17KB LargeMessageBufferPoolTest.java 15KB LiKafkaProducerIntegrationTest.java 15KB LiKafkaConsumer.java 13KB AbstractAuditor.java 13KB DeliveredMessageOffsetTracker.java 13KB LiKafkaConsumerConfig.java 13KB LargeMessageIntegrationTest.java 12KB LiKafkaInstrumentedProducerIntegrationTest.java 11KB LiKafkaInstrumentedConsumerIntegrationTest.java 11KB AbstractAuditorTest.java 11KB TestSslUtils.java 10KB LiKafkaProducerConfig.java 9KB LiKafkaClientsUtils.java 9KB LargeMessageBufferPool.java 8KB MessageSplitter.java 7KB MockLiKafkaConsumer.java 7KB EmbeddedBrokerBuilder.java 7KB MessageSplitterImpl.java 7KB MessageAssemblerTest.java 7KB AbstractKafkaClientsIntegrationTestHarness.java 6KB KafkaTestUtils.java 6KB LargeMessageHeaderValue.java 5KB LargeMessage.java 5KB EmbeddedBroker.java 5KB MessageAssemblerImpl.java 5KB AbstractKafkaIntegrationTestHarness.java 5KB PrimitiveEncoderDecoder.java 5KB ConsumerRecordsProcessResult.java 4KB LargeMessageSegment.java 4KB LargeMessageTest.java 4KB QueuedMap.java 4KB MessageAssembler.java 4KB LargeMessageOffsetTracker.java 3KB EmbeddedZookeeper.java 3KB MockLiKafkaProducer.java 3KB LoggingAuditor.java 3KB DefaultSegmentDeserializer.java 3KB CountingAuditStatsTest.java 3KB ConfigureAuditorTest.java 3KB LageMessageCallbackTest.java 3KB MessageSplitterTest.java 3KB CountingAuditStats.java 3KB LiKafkaConsumerRebalanceListener.java 3KB Auditor.java 3KB MetricsProxy.java 2KB KafkaIntegrationTestHarnessTest.java 2KB SerializerDeserializerTest.java 2KB CompositeMap.java 2KB KafkaConsumerLock.java 2KB PrimitiveEncoderDecoderTest.java 2KB CompositeSet.java 2KB LargeMessageCallback.java 2KB LiKafkaClientsTestUtils.java 2KB QueuedMapTest.java 2KB CompositeCollection.java 2KB InstrumentedClientLoggingHandler.java 2KB LiKafkaClientsTestUtils.java 2KB EmbeddedBrokerTest.java 2KB DefaultSegmentSerializer.java 2KB LiKafkaOffsetCommitCallback.java 2KB CompositeMapTest.java 2KB AuditKey.java 2KB DefaultSegmentDeserializerTest.java 1KB EmbeddedZookeeperTest.java 1KB ClusterDescriptor.java 1KB LiKafkaCommonClientConfigs.java 1KB AuditStats.java 1KB UUIDFactory.java 1KB PartitionLookupResult.java 1KB ConsumerRecordsProcessingException.java 1KB LiKafkaProducer.java 1KB ClusterGroupDescriptor.java 1KB OffsetNotTrackedException.java 1KB TopicLookupResult.java 1KB AuditType.java 1KB RoundRobinPartitioner.java 1024B LiKafkaProducerBuilder.java 999B NoOpAuditor.java 922B LiKafkaConsumerSSLIntegrationTest.java 913B CompositeIterator.java 888B LiKafkaProducerSSLIntegrationTest.java 872B共 134 条
- 1
- 2
资源评论
大白兔奶棠
- 粉丝: 25
- 资源: 4661
最新资源
- ZArchiver.Pro_0.9.5.apk
- vmware环境配置.mp4
- 548springboot + vue 大学生社团活动平台.zip（可运行源码+数据库文件+文档）
- 微信小程序 辩论倒计时小程序源码 作业设计demo 计算机专业参考
- 深入探究文件IO，嵌入式Linux
- 微信备忘录小程序源码 作业设计demo 计算机专业作业
- 微信小程序 仿百度小说小程序 看小说小程序 实现源码
- 锂电资料包-锂离子电池技术干货资料合集.zip
- EMC EMI资料大全电磁兼容电磁干扰设计资料工程师必备经验资料35个合集.zip
- 547springboot + vue 交流互动系统.zip（可运行源码+数据库文件+文档）
资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！
点击此处反馈
