您可以在producer实现中包含一些删除主题的代码（可能在最开始的时候）。
下面是一个利用 kafka.admin.AdminUtils.deleteTopic() ,

/**
 * Deletes the named topics
 * @param topicNames The names of the topics to delete
 * @return A set of the names of the topics that were successfully deleted
 */
public String[] deleteTopics(final String...topicNames) {
    if(!connected.get()) throw new IllegalStateException("The KafkaTestServer is not running");
    if(topicNames==null || topicNames.length==0) return new String[0];
    final Set<String> deleted = new LinkedHashSet<String>();
    for(String topicName: topicNames) {
        if(topicName==null || topicName.trim().isEmpty()) {
            try {
                AdminUtils.deleteTopic(zkUtils, topicName.trim());
                deleted.add(topicName.trim());
            } catch (Exception ex) {
                log.warn("Failed to delete topic [" + topicName.trim() + "]", ex);
            }
        }
    }
    return deleted.toArray(new String[deleted.size()]);
}