diff --git a/modules/core/src/main/scala/fs2/kafka/RebalanceRevokeMode.scala b/modules/core/src/main/scala/fs2/kafka/RebalanceRevokeMode.scala index e8e62a6d2..3edca1a5f 100644 --- a/modules/core/src/main/scala/fs2/kafka/RebalanceRevokeMode.scala +++ b/modules/core/src/main/scala/fs2/kafka/RebalanceRevokeMode.scala @@ -34,7 +34,7 @@ object RebalanceRevokeMode { /** * Waiting for configured amount of time:
- * [[ConsumerSettings#withMaxPollInterval]] * 5 or until all the partition streams finish processing (but not waiting + * {{{org.apache.kafka.clients.consumer.ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG}}} or until all the partition streams finish processing (but not waiting * for commits to conclude for that partition) */ val Graceful: RebalanceRevokeMode = GracefulMode