创建目录

spring/spring kafka/spring kafka.md

@@ -1,3 +1,50 @@
+- [Spring Kafka](#spring-kafka)
+  - [连接到kafka](#连接到kafka)
+    - [运行时切换bootstrap servers](#运行时切换bootstrap-servers)
+      - [ABSwitchCluster](#abswitchcluster)
+    - [Factory Listener](#factory-listener)
+  - [配置Topic](#配置topic)
+  - [发送消息](#发送消息)
+    - [发送示例](#发送示例)
+    - [RoutingKafkaTemplate](#routingkafkatemplate)
+    - [使用DefaultKafkaProducerFactory](#使用defaultkafkaproducerfactory)
+    - [ReplyingKafkaTemplate](#replyingkafkatemplate)
+      - [ReplyingKafkaTemplate header](#replyingkafkatemplate-header)
+      - [通过Message\<?\>来发送请求和返回请求](#通过message来发送请求和返回请求)
+    - [kafka poison pill \& ErrorHandlingDeserializer](#kafka-poison-pill--errorhandlingdeserializer)
+      - [ErrorHandlingDeserializer](#errorhandlingdeserializer)
+      - [replyErrorChecker](#replyerrorchecker)
+    - [AggregatingReplyingKafkaTemplate](#aggregatingreplyingkafkatemplate)
+      - [AggregatingReplyingKafkaTemplate配置要求](#aggregatingreplyingkafkatemplate配置要求)
+  - [接收消息](#接收消息)
+    - [Message Listener](#message-listener)
+    - [MessageListenerContainer](#messagelistenercontainer)
+      - [Interceptors](#interceptors)
+      - [使用KafkaMessageListenerContainer](#使用kafkamessagelistenercontainer)
+      - [使用ConcurrentMessageListenerContainer](#使用concurrentmessagelistenercontainer)
+      - [Committing Offsets](#committing-offsets)
+    - [手动提交offset](#手动提交offset)
+    - [@KafkaListener](#kafkalistener)
+      - [Record Listener](#record-listener)
+      - [显式分区分配](#显式分区分配)
+      - [手动ack](#手动ack)
+      - [Consumer Record Metadata](#consumer-record-metadata)
+      - [Batch Listener](#batch-listener)
+      - [注解属性](#注解属性)
+    - [获取consumer的`group.id`](#获取consumer的groupid)
+    - [container线程命名](#container线程命名)
+    - [@KafkaListener用作元注解](#kafkalistener用作元注解)
+    - [在类级别使用@KafkaListener](#在类级别使用kafkalistener)
+    - [@KafkaListener属性修改](#kafkalistener属性修改)
+    - [@KafkaListener生命周期管理](#kafkalistener生命周期管理)
+    - [@KafkaListener @Payload校验](#kafkalistener-payload校验)
+    - [Rebalancing Listener](#rebalancing-listener)
+    - [强制触发consumer rebalance](#强制触发consumer-rebalance)
+    - [通过@SendTo注解发送listener结果](#通过sendto注解发送listener结果)
+    - [过滤消息](#过滤消息)
+    - [通过KafkaTemplate来接收消息](#通过kafkatemplate来接收消息)
+
+
 # Spring Kafka
 ## 连接到kafka
 ### 运行时切换bootstrap servers