我在一个模块上工作，要求有一个生产者，我们使用kafka作为数据产生的队列，并将其提供给消费者。
现在在consumer中，我尝试至少实现一次消息传递场景。
为此，我必须汇集来自kafka的消息，然后使用这些消息。在使用这些消息之后，我将调用consumer.commitasync（offset，callback）。
我想知道会发生什么
案例1）。当commitasync（）api从未被调用时（假设在调用这个api之前发生了异常）；但事实并非如此，消费者再也得不到这些数据了。
案例2）。如果使用者重新启动。
下面是使用使用者设置的属性的代码片段

private Properties getConsumerProperties() {
        final Properties props = new Properties();
        props.put(BOOTSTRAP_SERVERS_CONFIG, "server");
        props.put(GROUP_ID_CONFIG, "groupName");
        props.put(ENABLE_AUTO_COMMIT_CONFIG, false);
        props.put(HEARTBEAT_INTERVAL_MS_CONFIG, heartBeatinterval);
        props.put(METADATA_MAX_AGE_CONFIG, metaDataMaxAge);
        props.put(SESSION_TIMEOUT_MS_CONFIG, sessionTimeout);
        props.put(AUTO_OFFSET_RESET_CONFIG, autoOffsetReset);
        props.put(KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
        props.put(VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
        return props;
    }

现在在消费的基础上，一些属性设置；我有3个主题，为每个主题创建3个消费者（因为Kafka有3个分区和3个代理）。
对于数据的消耗…我根据从kafka接收到的某些属性来标识数据包..并将其传递给相关的主题（我为不同的主题使用了不同的线程池，并根据数据包中的属性创建任务并提交给线程池），处理之后，我调用consumer.commitasync（offset，callback）。
我期待着同样的消息会再次从Kafka的情况下commitasync是不是呼吁一些数据包…但我惊讶的是，它不会回来…我错过了什么。有什么样的设置，我们需要做的ApacheKafka以及至少一个。
请建议。