Kafka排除订阅的主题

在 Kafka 消费者中，可以使用 exclude 方法来排除某些主题的订阅。具体实现方式如下：

String bootstrapServer = "localhost:9092";
String groupId = "my-group";
List<String> topics = Arrays.asList("foo", "bar", "baz");
List<String> excludeTopics = Arrays.asList("baz");

Properties props = new Properties();
props.put("bootstrap.servers", bootstrapServer);
props.put("group.id", groupId);

KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
consumer.subscribe(topics);
consumer.exclude(excludeTopics);

while (true) {
    ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));
    // 处理消息
}

在上面的代码中，首先创建 Kafka 消费者，并为其设置一些基本属性，如 bootstrap.servers 和 group.id。然后，将需要订阅的主题列表以及需要排除的主题列表分别作为参数传递给 subscribe 和 exclude 方法。在消费消息时，只有订阅列表中的主题会被消费者拉取消息，排除列表中的主题会被忽略。

需要注意的是，exclude 方法只影响消费者拉取消息的行为，如果消息已经被投递到了消费者，那么无论该消息是否在排除列表中，消费者都会处理该消息。因此，如果需要完全拒绝某些主题的消息，请在消费者处理消息时进行相应的过滤。