Can't use more than one Consumer

[xwlcn]

yml:

bindings:
        store-in-0:
          group: torrent-store-group
          destination: torrentMessages
          contentType: application/json
          consumer:
            batch-mode: true
            compressionType: gzip
            autoCommitOffset: false
        index-in-0:
          group: torrent-index-group
          destination: torrentMessages
          contentType: application/json
          consumer:
            batch-mode: true
            max-poll-records: 100
            compressionType: gzip
            autoCommitOffset: false

java:

@Slf4j
@SpringBootApplication
public class TorrentStoreServiceApplication {

    @Autowired
    private TorrentService torrentService;
    public static Boolean filterXxx;
    @Value("${dodder.filter-sensitive-torrent}")
    public void setFilterXxx(Boolean filterXxx) {
        TorrentStoreServiceApplication.filterXxx = filterXxx;
    }

    public static void main(String[] args) {
        SpringApplication.run(TorrentStoreServiceApplication.class, args);
    }

    @Bean
    Consumer<Message<List<Torrent>>> index() {
        return message -> {
            try {
                Acknowledgment acknowledgment = message.getHeaders().get(KafkaHeaders.ACKNOWLEDGMENT, Acknowledgment.class);
                List<Torrent> torrents = message.getPayload();
                //System.out.println(torrents);
                //torrentService.index(torrents);
                //no error, execute acknowledge
                if (acknowledgment != null) {
                    acknowledgment.acknowledge();
                }
            } catch (Exception e) {
                log.error("Insert or update torrent error: {}", e);
            }
        };
    }

    @Bean
    Consumer<Message<List<Torrent>>> store() {
        return message -> {
            try {
                Acknowledgment acknowledgment = message.getHeaders().get(KafkaHeaders.ACKNOWLEDGMENT, Acknowledgment.class);
                List<Torrent> torrents = message.getPayload();
                System.out.println(torrents);
                torrentService.upsert(torrents);
                //no error, execute acknowledge
                if (acknowledgment != null) {
                    acknowledgment.acknowledge();
                }
            } catch (Exception e) {
                log.error("Insert or update torrent error: {}", e);
            }
        };
    }
}

console info:

Found more then one function beans in BeanFactory: [index, store]. If you did not intend to use functions, ignore this message. However, if you did intend to use functions in the context of spring-cloud-function, consider providing 'spring.cloud.function.definition' property pointing to a function bean(s) you intend to use. For example, 'spring.cloud.function.definition=myFunction'

Before using version 2.X, use @StreamListener annotation had no problem, but I wanted to do batch processing. Two different groups consumed the same topic, and the above code could not run correctly. I needed to comment out a consumer method will it can be run.

[xwlcn]

Addspring.cloud.function.definition=index;store it works.