如何删除kafka中被标记的topic

要删除 Kafka 中被标记的 topic，需要执行以下步骤：

1. 确认 Kafka 版本是否支持删除 topic 功能。Kafka 0.11.0.0 版本之后支持删除 topic，如果你的版本低于此，需要升级 Kafka 版本。

2. 在 Kafka 集群中找到一个 broker，运行以下命令：

bin/kafka-topics.sh --delete --zookeeper <zookeeper-host>:<zookeeper-port> --topic <topic-name>

其中，`<zookeeper-host>` 是 ZooKeeper 的主机名或 IP 地址，`<zookeeper-port>` 是 ZooKeeper 的端口号，默认为 2181。`<topic-name>` 是要删除的 topic 名称。

3. 确认 topic 是否已被删除。你可以使用以下命令列出 Kafka 集群中所有的 topic：

bin/kafka-topics.sh --list --zookeeper <zookeeper-host>:<zookeeper-port>

如果你无法再看到要删除的 topic，说明已经成功删除了。

相关问题

如何彻底删除kafka中被标记的topic

要彻底删除 Kafka 中被标记的 topic，需要进行以下步骤：

1. 在删除 topic 前，需要先将该 topic 的所有 partitions 的 replicas 数量都设置为 0，这可以通过修改 topic 的 partition 副本数量来实现。

2. 在 Kafka 集群中运行 Kafka 的脚本工具 kafka-topics.sh，执行以下命令：

bin/kafka-topics.sh --delete --zookeeper <zookeeper_connect_string> --topic <topic_name>

其中，<zookeeper_connect_string> 是 Kafka 集群使用的 ZooKeeper 的连接字符串，<topic_name> 是要删除的 topic 名称。

3. 确认 topic 已被删除，可以通过以下命令来获取 topic 列表：

bin/kafka-topics.sh --list --zookeeper <zookeeper_connect_string>

如果 topic 列表中不包含被删除的 topic，则说明删除成功。

需要注意的是，删除 topic 的操作是不可逆的，请谨慎操作。此外，在删除 topic 后，所有与该 topic 相关的数据都将被永久删除，因此在执行删除操作前，需要备份相关数据以进行恢复。

Springboot集成kafka消费指定的topic

要在Spring Boot应用程序中集成Kafka消费者，您需要完成以下步骤：

1. 引入Kafka客户端依赖项

在Maven或Gradle构建文件中添加Kafka客户端依赖项。例如，在Maven中添加以下依赖项：

<dependency>
  <groupId>org.springframework.kafka</groupId>
  <artifactId>spring-kafka</artifactId>
  <version>2.6.7</version>
</dependency>

2. 配置Kafka消费者

在Spring Boot应用程序中，您可以使用application.properties或application.yml文件配置Kafka消费者。以下是一个示例application.yml文件：

spring.kafka.consumer.bootstrap-servers=localhost:9092
spring.kafka.consumer.group-id=my-group
spring.kafka.consumer.auto-offset-reset=earliest
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer

这些属性指定了Kafka消费者连接到的Kafka服务器，消费者所属的消费组以及如何处理消费者从Kafka服务器读取的消息。

3. 创建Kafka消费者

在Spring Boot应用程序中，您可以使用Spring Kafka提供的KafkaTemplate类来创建Kafka消费者。以下是一个示例代码片段：

@Service
public class KafkaConsumerService {
 
    @KafkaListener(topics = "my-topic")
    public void listen(String message) {
        // 处理接收到的消息
    }
}

使用@KafkaListener注释将这个方法标记为Kafka消费者。在这个示例中，消费者订阅名为“my-topic”的Kafka主题，并在接收到消息时调用listen()方法。

4. 运行应用程序

现在，您可以运行Spring Boot应用程序并开始使用Kafka消费者。当有新的消息发布到“my-topic”主题时，Kafka消费者将自动从Kafka服务器读取消息并将其发送到KafkaConsumerService类的listen()方法中进行处理。

注意：在运行应用程序之前，请确保Kafka服务器正在运行，并且“my-topic”主题已经创建。