Spring Cloud Stream:绑定器与消费组

  Kafka 里新出现的 topic:['__consumer_offsets', 'in-in-0']
  消费组列表:['anonymous.258622ca-b725-4db5-a927-76e9da123814']
  往 in-in-0 发 m1:['a in 收到 m1 (分区 0)']
  发 m1 之后的消费组:['anonymous.258622ca-b725-4db5-a927-76e9da123814']

  [没有 group] 两个实例,同一个 topic:a1 收到 8 条,a2 收到 8 条;消费组 = ['anonymous.…258622ca-b725-4db5-a927-76e9da123814', 'anonymous.…da77a8d2-4701-4c
  [group=g1] 两个实例:b1 收到 4 条(分区 ['0']),b2 收到 4 条(分区 ['1']),合计 8 条

  具名消费组 newgroup 第一次启动:['e1 (分区 0)', 'e2 (分区 0)', 'e3 (分区 0)']
  匿名(没有 group)启动:没有收到任何历史消息

  默认配置:bad-1 的处理日志:['处理 bad-1 抛异常(第 1 次)', '处理 bad-1 抛异常(第 2 次)', '处理 bad-1 抛异常(第 3 次)'];ok-2 是否收到:True
  重启后同一个消费组再启动,是否又收到 bad-1:False
  enableDlq=true:bad-9 被处理了 3 次;Kafka 里的 topic 有 ['error.t-dlq.gdlq', 't-dlq']
  DLQ topic 里的内容:['bad-9']

  新出现的 topic:[]
  发到 in-in-0 与 other-in-0 各一条之后收到:[]
  配了 spring.cloud.function.definition=in;other:['in 收到 y1 (分区 0)', 'other 收到 y2 (分区 0)']