更新license

2026-05-04 18:09:54 +08:00 · 2025-03-04 10:42:17 +08:00
parent 922b0f0dee
commit 6be6b88190
297 changed files with 1199 additions and 594 deletions
--- a/jcpp-infrastructure-queue/pom.xml
+++ b/jcpp-infrastructure-queue/pom.xml
@@ -1,8 +1,10 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!--

-    抖音关注：程序员三丙
-    知识星球：https://t.zsxq.com/j9b21
+    开源代码，仅供学习和交流研究使用，商用请联系三丙
+    微信：mohan_88888
+    抖音：程序员三丙
+    付费课程知识星球：https://t.zsxq.com/aKtXo

 -->
 <project xmlns="http://maven.apache.org/POM/4.0.0"
--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/AbstractQueueConsumerTemplate.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/AbstractQueueConsumerTemplate.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/Callback.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/Callback.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/DefaultQueueMsg.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/DefaultQueueMsg.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/DefaultQueueMsgHeaders.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/DefaultQueueMsgHeaders.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/KafkaQueueMsg.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/KafkaQueueMsg.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/PackCallback.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/PackCallback.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/PackProcessingContext.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/PackProcessingContext.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/ProtoQueueMsg.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/ProtoQueueMsg.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/QueueAdmin.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/QueueAdmin.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/QueueCallback.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/QueueCallback.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/QueueConsumer.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/QueueConsumer.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/QueueMsg.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/QueueMsg.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/QueueMsgHeaders.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/QueueMsgHeaders.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/QueueMsgMetadata.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/QueueMsgMetadata.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/QueueProducer.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/QueueProducer.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/common/QueueConfig.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/common/QueueConfig.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue.common;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/common/QueueConstants.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/common/QueueConstants.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue.common;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/common/TopicPartitionInfo.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/common/TopicPartitionInfo.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue.common;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/discovery/DefaultServiceInfoProvider.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/discovery/DefaultServiceInfoProvider.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue.discovery;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/discovery/DiscoveryProvider.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/discovery/DiscoveryProvider.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue.discovery;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/discovery/DummyDiscoveryProvider.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/discovery/DummyDiscoveryProvider.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue.discovery;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/discovery/HashPartitionProvider.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/discovery/HashPartitionProvider.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue.discovery;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/discovery/PartitionProvider.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/discovery/PartitionProvider.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue.discovery;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/discovery/QueueKey.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/discovery/QueueKey.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue.discovery;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/discovery/ServiceInfoProvider.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/discovery/ServiceInfoProvider.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue.discovery;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/discovery/ServiceType.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/discovery/ServiceType.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue.discovery;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/discovery/ZkDiscoveryProvider.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/discovery/ZkDiscoveryProvider.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue.discovery;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/discovery/event/JCPPApplicationEvent.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/discovery/event/JCPPApplicationEvent.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue.discovery.event;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/discovery/event/JCPPApplicationEventListener.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/discovery/event/JCPPApplicationEventListener.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue.discovery.event;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/discovery/event/OtherServiceShutdownEvent.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/discovery/event/OtherServiceShutdownEvent.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue.discovery.event;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/discovery/event/PartitionChangeEvent.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/discovery/event/PartitionChangeEvent.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue.discovery.event;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/kafka/KafkaAdmin.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/kafka/KafkaAdmin.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue.kafka;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/kafka/KafkaConsumerStatisticConfig.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/kafka/KafkaConsumerStatisticConfig.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue.kafka;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/kafka/KafkaConsumerStatsService.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/kafka/KafkaConsumerStatsService.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue.kafka;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/kafka/KafkaConsumerTemplate.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/kafka/KafkaConsumerTemplate.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue.kafka;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/kafka/KafkaDecoder.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/kafka/KafkaDecoder.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue.kafka;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/kafka/KafkaProducerTemplate.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/kafka/KafkaProducerTemplate.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue.kafka;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/kafka/KafkaQueueMsgMetadata.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/kafka/KafkaQueueMsgMetadata.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue.kafka;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/kafka/KafkaSettings.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/kafka/KafkaSettings.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue.kafka;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/kafka/KafkaTopicConfigs.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/kafka/KafkaTopicConfigs.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue.kafka;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/memory/DefaultInMemoryStorage.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/memory/DefaultInMemoryStorage.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue.memory;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/memory/InMemoryQueueConsumer.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/memory/InMemoryQueueConsumer.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue.memory;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/memory/InMemoryQueueProducer.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/memory/InMemoryQueueProducer.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue.memory;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/memory/InMemoryStorage.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/memory/InMemoryStorage.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue.memory;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/processing/IdMsgPair.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/processing/IdMsgPair.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue.processing;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/provider/AppQueueFactory.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/provider/AppQueueFactory.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue.provider;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/provider/InMemoryAppQueueFactory.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/provider/InMemoryAppQueueFactory.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue.provider;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/provider/KafkaAppQueueFactory.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/provider/KafkaAppQueueFactory.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue.provider;

--- a/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/settings/QueueAppSettings.java
+++ b/jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/settings/QueueAppSettings.java
@@ -1,6 +1,8 @@
 /**
- * 抖音关注：程序员三丙
- * 知识星球：https://t.zsxq.com/j9b21
+ * 开源代码，仅供学习和交流研究使用，商用请联系三丙
+ * 微信：mohan_88888
+ * 抖音：程序员三丙
+ * 付费课程知识星球：https://t.zsxq.com/aKtXo
 */
 package sanbing.jcpp.infrastructure.queue.settings;