Kafka非阻塞重试，在订阅多个主题的消费者上使用topicPattern。

使用KafkaConsumer API中的assign()方法来分配多个主题，然后在轮询消息时使用非阻塞重试机制。

示例代码：

import java.util.*;
import org.apache.kafka.clients.consumer.*;

public class NonBlockingConsumer {

    public static void main(String[] args) {

        Properties props = new Properties();
        props.put("bootstrap.servers", "localhost:9092");
        props.put("group.id", "test-group");
        props.put("enable.auto.commit", "false");
        props.put("auto.offset.reset", "earliest");

        KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);

        // Use assign() to subscribe to multiple topics using topicPattern
        String topicPattern = "topic-*"; // assumes topics are named "topic-A", "topic-B", etc.
        consumer.assign(Collections.singletonList(new TopicPartition(topicPattern, 0)));

        while (true) {
            ConsumerRecords<String, String> records = consumer.poll(1000);

            for (ConsumerRecord<String, String> record : records) {
                // process each record
            }

            // Non-blocking retry logic
            if (!records.isEmpty()) {
                try {
                    consumer.commitSync();
                } catch (CommitFailedException e) {
                    // Handle exception and retry committing offsets
                }
            }
        }
    }
}